程序包 org.apache.flink.cdc.common.event

接口概要

接口	说明
ChangeEvent	Class ChangeEvent represents the change events of external systems, including DataChangeEvent and SchemaChangeEvent.
Event	Class Event is the super interface defines the events of external systems flowing into Flink CDC.
EventDeserializer<T>	Deserializer to deserialize given record to Event.
SchemaChangeEvent	Class SchemaChangeEvent represents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.
SchemaChangeEventWithPreSchema	A SchemaChangeEvent that supports appending schema before change event.

类概要

类	说明
AddColumnEvent	A SchemaChangeEvent that represents an ADD COLUMN DDL, which may contain the lenient column type changes.
AddColumnEvent.ColumnWithPosition	represents result of an ADD COLUMN DDL that may change column sequence.
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
DataChangeEvent	Class DataChangeEvent represents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.
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.
FlushEvent	An Event from SchemaOperator to notify DataSinkWriterOperator that it start flushing.
RenameColumnEvent	A SchemaChangeEvent that represents an RENAME COLUMN DDL, which may contain the lenient column type changes.
SchemaChangeEventTypeFamily	An enumeration of schema change event families for clustering SchemaChangeEvents into categories.
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.
TruncateTableEvent	A SchemaChangeEvent that represents an TRUNCATE TABLE DDL. this will be sent by DataSource before all DataChangeEvent with the same tableId.

枚举概要

枚举	说明
AddColumnEvent.ColumnPosition	relative Position of column.
OperationType	Enum OperationType describes the type of operation that the data change event reports.
SchemaChangeEventType	An enumeration of schema change event types for SchemaChangeEvent.