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

使用Event的程序包

程序包	说明
org.apache.flink.cdc.common.event
org.apache.flink.cdc.common.sink
org.apache.flink.cdc.common.source

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

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

限定符和类型	接口和说明
interface	ChangeEvent Class ChangeEvent represents the change events of external systems, including DataChangeEvent and SchemaChangeEvent.
interface	SchemaChangeEvent Class SchemaChangeEvent represents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.
interface	SchemaChangeEventWithPreSchema A SchemaChangeEvent that supports appending schema before change event.

实现Event的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	DataChangeEvent Class DataChangeEvent represents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.
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	FlushEvent An Event from SchemaOperator to notify DataSinkWriterOperator that it start flushing.
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.

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

限定符和类型	方法和说明
List<? extends Event>	EventDeserializer.deserialize(T record) Deserialize given record to Events.

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

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

限定符和类型	方法和说明
org.apache.flink.api.connector.sink2.Sink<Event>	FlinkSinkProvider.getSink() Get the Sink for writing events to external systems.
org.apache.flink.streaming.api.functions.sink.SinkFunction<Event>	FlinkSinkFunctionProvider.getSinkFunction() Get the SinkFunction for writing events to external systems.

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

限定符和类型	方法和说明
static FlinkSinkProvider	FlinkSinkProvider.of(org.apache.flink.api.connector.sink2.Sink<Event> sink) Create a FlinkSinkProvider from a Sink.
static FlinkSinkFunctionProvider	FlinkSinkFunctionProvider.of(org.apache.flink.streaming.api.functions.sink.SinkFunction<Event> sinkFunction) Create a FlinkSinkFunctionProvider from a SinkFunction.

org.apache.flink.cdc.common.source中Event的使用

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

限定符和类型	方法和说明
org.apache.flink.api.connector.source.Source<Event,?,?>	FlinkSourceProvider.getSource() Get the Source for reading events from external systems.
org.apache.flink.streaming.api.functions.source.SourceFunction<Event>	FlinkSourceFunctionProvider.getSourceFunction() Get the SourceFunction for reading events from external systems.

类型变量类型为Event的org.apache.flink.cdc.common.source中的方法参数

限定符和类型	方法和说明
static FlinkSourceProvider	FlinkSourceProvider.of(org.apache.flink.api.connector.source.Source<Event,?,?> source) Create a FlinkSourceProvider from a Source.
static FlinkSourceFunctionProvider	FlinkSourceFunctionProvider.of(org.apache.flink.streaming.api.functions.source.SourceFunction<Event> sourceFunction) Create a FlinkSourceFunctionProvider from a SourceFunction.