Uses of Interface
org.apache.paimon.schema.SchemaChange

Packages that use SchemaChange

Package	Description
org.apache.paimon.catalog
org.apache.paimon.flink
org.apache.paimon.flink.sink.cdc
org.apache.paimon.hive
org.apache.paimon.jdbc
org.apache.paimon.privilege
org.apache.paimon.schema

Uses of SchemaChange in org.apache.paimon.catalog

Methods in org.apache.paimon.catalog with parameters of type SchemaChange

Modifier and Type	Method and Description
default void	Catalog.alterTable(Identifier identifier, SchemaChange change, boolean ignoreIfNotExists) Modify an existing table from a SchemaChange.

Method parameters in org.apache.paimon.catalog with type arguments of type SchemaChange

Modifier and Type	Method and Description
void	DelegateCatalog.alterTable(Identifier identifier, List<SchemaChange> changes, boolean ignoreIfNotExists)
void	Catalog.alterTable(Identifier identifier, List<SchemaChange> changes, boolean ignoreIfNotExists) Modify an existing table from SchemaChanges.
void	AbstractCatalog.alterTable(Identifier identifier, List<SchemaChange> changes, boolean ignoreIfNotExists)
void	CachingCatalog.alterTable(Identifier identifier, List<SchemaChange> changes, boolean ignoreIfNotExists)
protected void	FileSystemCatalog.alterTableImpl(Identifier identifier, List<SchemaChange> changes)
protected abstract void	AbstractCatalog.alterTableImpl(Identifier identifier, List<SchemaChange> changes)

Uses of SchemaChange in org.apache.paimon.flink

Method parameters in org.apache.paimon.flink with type arguments of type SchemaChange

Modifier and Type	Method and Description
protected boolean	FlinkCatalog.handleMaterializedTableChange(org.apache.flink.table.catalog.TableChange change, List<SchemaChange> schemaChanges) Try handle change related to materialized table.

Uses of SchemaChange in org.apache.paimon.flink.sink.cdc

Methods in org.apache.paimon.flink.sink.cdc that return types with arguments of type SchemaChange

Modifier and Type	Method and Description
protected List<SchemaChange>	UpdatedDataFieldsProcessFunctionBase.extractSchemaChanges(SchemaManager schemaManager, List<DataField> updatedDataFields)

Methods in org.apache.paimon.flink.sink.cdc with parameters of type SchemaChange

Modifier and Type	Method and Description
protected void	UpdatedDataFieldsProcessFunctionBase.applySchemaChange(SchemaManager schemaManager, SchemaChange schemaChange, Identifier identifier)

Uses of SchemaChange in org.apache.paimon.hive

Method parameters in org.apache.paimon.hive with type arguments of type SchemaChange

Modifier and Type	Method and Description
protected void	HiveCatalog.alterTableImpl(Identifier identifier, List<SchemaChange> changes)

Uses of SchemaChange in org.apache.paimon.jdbc

Method parameters in org.apache.paimon.jdbc with type arguments of type SchemaChange

Modifier and Type	Method and Description
protected void	JdbcCatalog.alterTableImpl(Identifier identifier, List<SchemaChange> changes)

Uses of SchemaChange in org.apache.paimon.privilege

Method parameters in org.apache.paimon.privilege with type arguments of type SchemaChange

Modifier and Type	Method and Description
void	PrivilegedCatalog.alterTable(Identifier identifier, List<SchemaChange> changes, boolean ignoreIfNotExists)

Uses of SchemaChange in org.apache.paimon.schema

Classes in org.apache.paimon.schema that implement SchemaChange

Modifier and Type	Class and Description
static class	SchemaChange.AddColumn A SchemaChange to add a field.
static class	SchemaChange.DropColumn A SchemaChange to drop a field.
static class	SchemaChange.RemoveOption A SchemaChange to remove a table option.
static class	SchemaChange.RenameColumn A SchemaChange to rename a field.
static class	SchemaChange.SetOption A SchemaChange to set a table option.
static class	SchemaChange.UpdateColumnComment A SchemaChange to update the (nested) field comment.
static class	SchemaChange.UpdateColumnNullability A SchemaChange to update the (nested) field nullability.
static class	SchemaChange.UpdateColumnPosition A SchemaChange to update the field position.
static class	SchemaChange.UpdateColumnType A SchemaChange to update the field type.
static class	SchemaChange.UpdateComment A SchemaChange to Update table comment.

Methods in org.apache.paimon.schema that return SchemaChange

Modifier and Type	Method and Description
static SchemaChange	SchemaChange.addColumn(String[] fieldNames, DataType dataType, String comment, SchemaChange.Move move)
static SchemaChange	SchemaChange.addColumn(String fieldName, DataType dataType)
static SchemaChange	SchemaChange.addColumn(String fieldName, DataType dataType, String comment)
static SchemaChange	SchemaChange.addColumn(String fieldName, DataType dataType, String comment, SchemaChange.Move move)
static SchemaChange	SchemaChange.dropColumn(String fieldName)
static SchemaChange	SchemaChange.dropColumn(String[] fieldNames)
static SchemaChange	SchemaChange.removeOption(String key)
static SchemaChange	SchemaChange.renameColumn(String[] fieldNames, String newName)
static SchemaChange	SchemaChange.renameColumn(String fieldName, String newName)
static SchemaChange	SchemaChange.setOption(String key, String value)
static SchemaChange	SchemaChange.updateColumnComment(String[] fieldNames, String comment)
static SchemaChange	SchemaChange.updateColumnComment(String fieldName, String comment)
static SchemaChange	SchemaChange.updateColumnNullability(String[] fieldNames, boolean newNullability)
static SchemaChange	SchemaChange.updateColumnNullability(String fieldName, boolean newNullability)
static SchemaChange	SchemaChange.updateColumnPosition(SchemaChange.Move move)
static SchemaChange	SchemaChange.updateColumnType(String[] fieldNames, DataType newDataType, boolean keepNullability)
static SchemaChange	SchemaChange.updateColumnType(String fieldName, DataType newDataType)
static SchemaChange	SchemaChange.updateColumnType(String fieldName, DataType newDataType, boolean keepNullability)
static SchemaChange	SchemaChange.updateComment(String comment)

Methods in org.apache.paimon.schema with parameters of type SchemaChange

Modifier and Type	Method and Description
TableSchema	SchemaManager.commitChanges(SchemaChange... changes) Update SchemaChanges.

Method parameters in org.apache.paimon.schema with type arguments of type SchemaChange

Modifier and Type	Method and Description
TableSchema	SchemaManager.commitChanges(List<SchemaChange> changes) Update SchemaChanges.