Uses of Package
org.apache.flink.cdc.common.event
-
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.common.event Class Description AddColumnEvent.ColumnPosition relative Position of column.AddColumnEvent.ColumnWithPosition represents result of an ADD COLUMN DDL that may change column sequence.ChangeEvent ClassChangeEventrepresents the change events of external systems, includingDataChangeEventandSchemaChangeEvent.DataChangeEvent ClassDataChangeEventrepresents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC.OperationType EnumOperationTypedescribes the type of operation that the data change event reports.SchemaChangeEvent ClassSchemaChangeEventrepresents 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 forSchemaChangeEvent.SchemaChangeEventWithPreSchema ASchemaChangeEventthat 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.common.event.visitor Class Description AddColumnEvent ASchemaChangeEventthat represents anADD COLUMNDDL, which may contain the lenient column type changes.SchemaChangeEvent ClassSchemaChangeEventrepresents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.common.exceptions Class Description SchemaChangeEvent ClassSchemaChangeEventrepresents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.common.function Class Description 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.common.route Class Description 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.common.schema Class Description 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.common.sink Class Description DataChangeEvent ClassDataChangeEventrepresents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC.SchemaChangeEvent ClassSchemaChangeEventrepresents 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 forSchemaChangeEvent.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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.common.source Class Description Event ClassEventis 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.common.source.discover Class Description 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.common.utils Class Description DataChangeEvent ClassDataChangeEventrepresents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.SchemaChangeEvent ClassSchemaChangeEventrepresents 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 forSchemaChangeEvent.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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.composer.definition Class Description SchemaChangeEventType An enumeration of schema change event types forSchemaChangeEvent. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.composer.flink.translator Class Description DataChangeEvent ClassDataChangeEventrepresents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.doris.sink Class Description Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC.SchemaChangeEvent ClassSchemaChangeEventrepresents 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 forSchemaChangeEvent. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.doris.utils Class Description 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.elasticsearch.config Class Description 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.elasticsearch.serializer Class Description Event ClassEventis 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.fluss.sink Class Description DataChangeEvent ClassDataChangeEventrepresents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC.SchemaChangeEvent ClassSchemaChangeEventrepresents 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 forSchemaChangeEvent.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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.fluss.source Class Description 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.fluss.source.deserializer Class Description Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.fluss.source.discover Class Description 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.hudi.sink Class Description SchemaChangeEvent ClassSchemaChangeEventrepresents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.hudi.sink.bucket Class Description Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC.FlushEvent SchemaChangeEventType An enumeration of schema change event types forSchemaChangeEvent.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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.hudi.sink.event Class Description CreateTableEvent ASchemaChangeEventthat represents anCREATE TABLEDDL.Event ClassEventis 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.hudi.sink.function Class Description DataChangeEvent ClassDataChangeEventrepresents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC.FlushEvent SchemaChangeEvent ClassSchemaChangeEventrepresents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.hudi.sink.operator Class Description Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.hudi.sink.util Class Description ChangeEvent ClassChangeEventrepresents the change events of external systems, includingDataChangeEventandSchemaChangeEvent.DataChangeEvent ClassDataChangeEventrepresents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.hudi.sink.v2 Class Description Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.iceberg.sink Class Description SchemaChangeEvent ClassSchemaChangeEventrepresents 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 forSchemaChangeEvent. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.iceberg.sink.utils Class Description DataChangeEvent ClassDataChangeEventrepresents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.iceberg.sink.v2 Class Description Event ClassEventis 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.kafka.json Class Description Event ClassEventis 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.kafka.json.canal Class Description Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.kafka.json.debezium Class Description Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.kafka.serialization Class Description Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.kafka.sink Class Description Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC.SchemaChangeEvent ClassSchemaChangeEventrepresents 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 forSchemaChangeEvent. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.maxcompute Class Description DataChangeEvent ClassDataChangeEventrepresents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.SchemaChangeEvent ClassSchemaChangeEventrepresents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.maxcompute.coordinator Class Description Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.maxcompute.sink Class Description DataChangeEvent ClassDataChangeEventrepresents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.Event ClassEventis 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.maxcompute.utils Class Description AddColumnEvent.ColumnWithPosition represents result of an ADD COLUMN DDL that may change column sequence.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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.mysql.source Class Description EventDeserializer Deserializer to deserialize given record toEvent.SchemaChangeEvent ClassSchemaChangeEventrepresents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.mysql.source.parser Class Description SchemaChangeEvent ClassSchemaChangeEventrepresents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.mysql.source.reader Class Description Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.mysql.utils Class Description 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.oceanbase.sink Class Description Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC.SchemaChangeEvent ClassSchemaChangeEventrepresents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.oracle.source Class Description EventDeserializer Deserializer to deserialize given record toEvent.SchemaChangeEvent ClassSchemaChangeEventrepresents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.oracle.source.parser Class Description SchemaChangeEvent ClassSchemaChangeEventrepresents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.oracle.source.reader Class Description Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.oracle.utils Class Description 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.paimon.sink Class Description AddColumnEvent.ColumnWithPosition represents result of an ADD COLUMN DDL that may change column sequence.DataChangeEvent ClassDataChangeEventrepresents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC.SchemaChangeEvent ClassSchemaChangeEventrepresents 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 forSchemaChangeEvent.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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.paimon.sink.v2 Class Description DataChangeEvent ClassDataChangeEventrepresents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.Event ClassEventis 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.paimon.sink.v2.bucket Class Description ChangeEvent ClassChangeEventrepresents the change events of external systems, includingDataChangeEventandSchemaChangeEvent.DataChangeEvent ClassDataChangeEventrepresents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC.FlushEvent SchemaChangeEvent ClassSchemaChangeEventrepresents 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 forSchemaChangeEvent.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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.postgres.source Class Description EventDeserializer Deserializer to deserialize given record toEvent.SchemaChangeEvent ClassSchemaChangeEventrepresents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.postgres.utils Class Description SchemaChangeEvent ClassSchemaChangeEventrepresents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.sqlserver.source Class Description Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC.EventDeserializer Deserializer to deserialize given record toEvent.SchemaChangeEvent ClassSchemaChangeEventrepresents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.sqlserver.utils Class Description 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.starrocks.sink Class Description Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC.SchemaChangeEvent ClassSchemaChangeEventrepresents 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 forSchemaChangeEvent.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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.values Class Description DataChangeEvent ClassDataChangeEventrepresents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.SchemaChangeEvent ClassSchemaChangeEventrepresents 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 forSchemaChangeEvent.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 dedicatedTableId.TruncateTableEvent ASchemaChangeEventthat represents anTRUNCATE TABLEDDL. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.values.sink Class Description Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.connectors.values.source Class Description Event ClassEventis 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.debezium.event Class Description ChangeEvent ClassChangeEventrepresents the change events of external systems, includingDataChangeEventandSchemaChangeEvent.CreateTableEvent ASchemaChangeEventthat represents anCREATE TABLEDDL.DataChangeEvent ClassDataChangeEventrepresents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC.EventDeserializer Deserializer to deserialize given record toEvent.SchemaChangeEvent ClassSchemaChangeEventrepresents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.runtime.operators.schema.common Class Description CreateTableEvent ASchemaChangeEventthat represents anCREATE TABLEDDL.DataChangeEvent ClassDataChangeEventrepresents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.SchemaChangeEvent ClassSchemaChangeEventrepresents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.runtime.operators.schema.common.event Class Description 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.runtime.operators.schema.distributed Class Description Event ClassEventis 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.runtime.operators.schema.distributed.event Class Description SchemaChangeEvent ClassSchemaChangeEventrepresents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.runtime.operators.schema.regular Class Description Event ClassEventis 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.runtime.operators.schema.regular.event Class Description SchemaChangeEvent ClassSchemaChangeEventrepresents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.runtime.operators.sink Class Description Event ClassEventis 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.runtime.operators.sink.exception Class Description Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.runtime.operators.transform Class Description CreateTableEvent ASchemaChangeEventthat represents anCREATE TABLEDDL.Event ClassEventis 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.runtime.operators.transform.async Class Description Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.runtime.operators.transform.converter Class Description DataChangeEvent ClassDataChangeEventrepresents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.runtime.operators.transform.exceptions Class Description Event ClassEventis 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.runtime.partitioning Class Description DataChangeEvent ClassDataChangeEventrepresents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.runtime.serializer Class Description 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 dedicatedTableId. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.runtime.serializer.event Class Description AddColumnEvent ASchemaChangeEventthat represents anADD COLUMNDDL, which may contain the lenient column type changes.AlterColumnTypeEvent ASchemaChangeEventthat represents anALTER COLUMNDDL, which may contain the lenient column type changes.AlterTableCommentEvent CreateTableEvent ASchemaChangeEventthat represents anCREATE TABLEDDL.DataChangeEvent ClassDataChangeEventrepresents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.DropColumnEvent ASchemaChangeEventthat represents anDROP COLUMNDDL, which may contain the lenient column type changes.DropTableEvent ASchemaChangeEventthat represents anDROP TABLEDDL.Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC.RenameColumnEvent ASchemaChangeEventthat represents anRENAME COLUMNDDL, which may contain the lenient column type changes.SchemaChangeEvent ClassSchemaChangeEventrepresents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.TruncateTableEvent ASchemaChangeEventthat represents anTRUNCATE TABLEDDL. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.runtime.serializer.schema Class Description AddColumnEvent.ColumnWithPosition represents result of an ADD COLUMN DDL that may change column sequence. -
Classes in org.apache.flink.cdc.common.event used by org.apache.flink.cdc.runtime.typeutils Class Description Event ClassEventis the super interface defines the events of external systems flowing into Flink CDC.