Package org.apache.flink.cdc.common.event

Interface Summary

Interface	Description
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.

Class Summary

Class	Description
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.
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.
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.

Enum Summary

Enum	Description
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.