接口的使用
org.apache.flink.cdc.common.event.SchemaChangeEvent

使用SchemaChangeEvent的程序包

程序包	说明
org.apache.flink.cdc.common.event
org.apache.flink.cdc.common.event.visitor
org.apache.flink.cdc.common.exceptions
org.apache.flink.cdc.common.sink
org.apache.flink.cdc.common.utils

org.apache.flink.cdc.common.event中SchemaChangeEvent的使用

org.apache.flink.cdc.common.event中SchemaChangeEvent的子接口

限定符和类型	接口和说明
interface	SchemaChangeEventWithPreSchema A SchemaChangeEvent that supports appending schema before change event.

实现SchemaChangeEvent的org.apache.flink.cdc.common.event中的类

限定符和类型	类和说明
class	AddColumnEvent A SchemaChangeEvent that represents an ADD COLUMN DDL, which may contain the lenient column type changes.
class	AlterColumnTypeEvent A SchemaChangeEvent that represents an ALTER COLUMN DDL, which may contain the lenient column type changes.
class	CreateTableEvent A SchemaChangeEvent that represents an CREATE TABLE DDL. this will be sent by DataSource before all DataChangeEvent with the same tableId
class	DropColumnEvent A SchemaChangeEvent that represents an DROP COLUMN DDL, which may contain the lenient column type changes.
class	DropTableEvent A SchemaChangeEvent that represents an DROP TABLE DDL. this will be sent by DataSource before all DataChangeEvent with the same tableId.
class	RenameColumnEvent A SchemaChangeEvent that represents an RENAME COLUMN DDL, which may contain the lenient column type changes.
class	TruncateTableEvent A SchemaChangeEvent that represents an TRUNCATE TABLE DDL. this will be sent by DataSource before all DataChangeEvent with the same tableId.

返回SchemaChangeEvent的org.apache.flink.cdc.common.event中的方法

限定符和类型	方法和说明
SchemaChangeEvent	DropColumnEvent.copy(TableId newTableId)
SchemaChangeEvent	CreateTableEvent.copy(TableId newTableId)
SchemaChangeEvent	DropTableEvent.copy(TableId newTableId)
SchemaChangeEvent	TruncateTableEvent.copy(TableId newTableId)
SchemaChangeEvent	RenameColumnEvent.copy(TableId newTableId)
SchemaChangeEvent	SchemaChangeEvent.copy(TableId newTableId) Creates a copy of SchemaChangeEvent with new TableId.
SchemaChangeEvent	AlterColumnTypeEvent.copy(TableId newTableId)
SchemaChangeEvent	AddColumnEvent.copy(TableId newTableId)

参数类型为SchemaChangeEvent的org.apache.flink.cdc.common.event中的方法

限定符和类型	方法和说明
static SchemaChangeEventType	SchemaChangeEventType.ofEvent(SchemaChangeEvent event)

org.apache.flink.cdc.common.event.visitor中SchemaChangeEvent的使用

参数类型为SchemaChangeEvent的org.apache.flink.cdc.common.event.visitor中的方法

限定符和类型

方法和说明

static <T,E extends Throwable> T

SchemaChangeEventVisitor.visit(SchemaChangeEvent event, AddColumnEventVisitor<T,E> addColumnVisitor, AlterColumnTypeEventVisitor<T,E> alterColumnTypeEventVisitor, CreateTableEventVisitor<T,E> createTableEventVisitor, DropColumnEventVisitor<T,E> dropColumnEventVisitor, DropTableEventVisitor<T,E> dropTableEventVisitor, RenameColumnEventVisitor<T,E> renameColumnEventVisitor, TruncateTableEventVisitor<T,E> truncateTableEventVisitor)

org.apache.flink.cdc.common.exceptions中SchemaChangeEvent的使用

声明为SchemaChangeEvent的org.apache.flink.cdc.common.exceptions中的字段

限定符和类型	字段和说明
protected SchemaChangeEvent	SchemaEvolveException.applyingEvent

返回SchemaChangeEvent的org.apache.flink.cdc.common.exceptions中的方法

限定符和类型	方法和说明
SchemaChangeEvent	SchemaEvolveException.getApplyingEvent()

参数类型为SchemaChangeEvent的org.apache.flink.cdc.common.exceptions中的构造器

构造器和说明
SchemaEvolveException(SchemaChangeEvent applyingEvent, String exceptionMessage)
SchemaEvolveException(SchemaChangeEvent applyingEvent, String exceptionMessage, Throwable cause)
UnsupportedSchemaChangeEventException(SchemaChangeEvent applyingEvent)
UnsupportedSchemaChangeEventException(SchemaChangeEvent applyingEvent, String exceptionMessage)
UnsupportedSchemaChangeEventException(SchemaChangeEvent applyingEvent, String exceptionMessage, Throwable cause)

org.apache.flink.cdc.common.sink中SchemaChangeEvent的使用

参数类型为SchemaChangeEvent的org.apache.flink.cdc.common.sink中的方法

限定符和类型	方法和说明
void	MetadataApplier.applySchemaChange(SchemaChangeEvent schemaChangeEvent) Apply the given SchemaChangeEvent to external systems.

org.apache.flink.cdc.common.utils中SchemaChangeEvent的使用

返回SchemaChangeEvent的org.apache.flink.cdc.common.utils中的方法

限定符和类型	方法和说明
static SchemaChangeEvent	ChangeEventUtils.recreateSchemaChangeEvent(SchemaChangeEvent schemaChangeEvent, TableId tableId)

返回变量类型为SchemaChangeEvent的类型的org.apache.flink.cdc.common.utils中的方法

限定符和类型	方法和说明
static List<SchemaChangeEvent>	SchemaMergingUtils.getSchemaDifference(TableId tableId, Schema beforeSchema, Schema afterSchema) Generating what schema change events we need to do by converting compatible beforeSchema to afterSchema.
static Optional<SchemaChangeEvent>	SchemaUtils.transformSchemaChangeEvent(boolean hasAsterisk, List<String> referencedColumns, SchemaChangeEvent event) This function determines if the given schema change event event should be sent to downstream based on if the given transform rule has asterisk, and what columns are referenced.

参数类型为SchemaChangeEvent的org.apache.flink.cdc.common.utils中的方法

限定符和类型	方法和说明
static Schema	SchemaUtils.applySchemaChangeEvent(Schema schema, SchemaChangeEvent event) apply SchemaChangeEvent to the old schema and return the schema after changing.
static boolean	SchemaUtils.isSchemaChangeEventRedundant(Schema currentSchema, SchemaChangeEvent event) This function checks if the given schema change event has been applied already.
static SchemaChangeEvent	ChangeEventUtils.recreateSchemaChangeEvent(SchemaChangeEvent schemaChangeEvent, TableId tableId)
static Optional<SchemaChangeEvent>	SchemaUtils.transformSchemaChangeEvent(boolean hasAsterisk, List<String> referencedColumns, SchemaChangeEvent event) This function determines if the given schema change event event should be sent to downstream based on if the given transform rule has asterisk, and what columns are referenced.