程序包的使用
org.apache.flink.cdc.common.event

使用org.apache.flink.cdc.common.event的程序包

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

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

类和说明
AddColumnEvent.ColumnPosition relative Position of column.
AddColumnEvent.ColumnWithPosition represents result of an ADD COLUMN DDL that may change column sequence.
ChangeEvent Class ChangeEvent represents the change events of external systems, including DataChangeEvent and SchemaChangeEvent.
DataChangeEvent Class DataChangeEvent represents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.
Event Class Event is the super interface defines the events of external systems flowing into Flink CDC.
OperationType Enum OperationType describes the type of operation that the data change event reports.
SchemaChangeEvent Class SchemaChangeEvent represents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.
SchemaChangeEventType An enumeration of schema change event types for SchemaChangeEvent.
SchemaChangeEventWithPreSchema A SchemaChangeEvent that supports appending schema before change event.
TableId The unique identifier used to represent the path of external table or external data collection, all external system data collection could map to a dedicated TableId.

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

类和说明
AddColumnEvent A SchemaChangeEvent that represents an ADD COLUMN DDL, which may contain the lenient column type changes.
AlterColumnTypeEvent A SchemaChangeEvent that represents an ALTER COLUMN DDL, which may contain the lenient column type changes.
CreateTableEvent A SchemaChangeEvent that represents an CREATE TABLE DDL. this will be sent by DataSource before all DataChangeEvent with the same tableId
DropColumnEvent A SchemaChangeEvent that represents an DROP COLUMN DDL, which may contain the lenient column type changes.
DropTableEvent A SchemaChangeEvent that represents an DROP TABLE DDL. this will be sent by DataSource before all DataChangeEvent with the same tableId.
RenameColumnEvent A SchemaChangeEvent that represents an RENAME COLUMN DDL, which may contain the lenient column type changes.
SchemaChangeEvent Class SchemaChangeEvent represents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.
TruncateTableEvent A SchemaChangeEvent that represents an TRUNCATE TABLE DDL. this will be sent by DataSource before all DataChangeEvent with the same tableId.

org.apache.flink.cdc.common.exceptions使用的org.apache.flink.cdc.common.event中的类

类和说明
SchemaChangeEvent Class SchemaChangeEvent represents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.

org.apache.flink.cdc.common.function使用的org.apache.flink.cdc.common.event中的类

类和说明
TableId The unique identifier used to represent the path of external table or external data collection, all external system data collection could map to a dedicated TableId.

org.apache.flink.cdc.common.schema使用的org.apache.flink.cdc.common.event中的类

类和说明
TableId The unique identifier used to represent the path of external table or external data collection, all external system data collection could map to a dedicated TableId.

org.apache.flink.cdc.common.sink使用的org.apache.flink.cdc.common.event中的类

类和说明
DataChangeEvent Class DataChangeEvent represents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.
Event Class Event is the super interface defines the events of external systems flowing into Flink CDC.
SchemaChangeEvent Class SchemaChangeEvent represents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.
SchemaChangeEventType An enumeration of schema change event types for SchemaChangeEvent.
TableId The unique identifier used to represent the path of external table or external data collection, all external system data collection could map to a dedicated TableId.

org.apache.flink.cdc.common.source使用的org.apache.flink.cdc.common.event中的类

类和说明
Event Class Event is the super interface defines the events of external systems flowing into Flink CDC.
TableId The unique identifier used to represent the path of external table or external data collection, all external system data collection could map to a dedicated TableId.

org.apache.flink.cdc.common.utils使用的org.apache.flink.cdc.common.event中的类

类和说明
DataChangeEvent Class DataChangeEvent represents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.
SchemaChangeEvent Class SchemaChangeEvent represents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.
SchemaChangeEventType An enumeration of schema change event types for SchemaChangeEvent.
TableId The unique identifier used to represent the path of external table or external data collection, all external system data collection could map to a dedicated TableId.