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

使用DataChangeEvent的程序包

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

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

返回DataChangeEvent的org.apache.flink.cdc.common.event中的方法

限定符和类型	方法和说明
static DataChangeEvent	DataChangeEvent.deleteEvent(TableId tableId, RecordData before) Creates a DataChangeEvent instance that describes the delete event.
static DataChangeEvent	DataChangeEvent.deleteEvent(TableId tableId, RecordData before, Map<String,String> meta) Creates a DataChangeEvent instance that describes the delete event with meta info.
static DataChangeEvent	DataChangeEvent.insertEvent(TableId tableId, RecordData after) Creates a DataChangeEvent instance that describes the insert event.
static DataChangeEvent	DataChangeEvent.insertEvent(TableId tableId, RecordData after, Map<String,String> meta) Creates a DataChangeEvent instance that describes the insert event with meta info.
static DataChangeEvent	DataChangeEvent.projectAfter(DataChangeEvent dataChangeEvent, RecordData projectedAfter) Updates the after of a DataChangeEvent instance that describes the event with meta info.
static DataChangeEvent	DataChangeEvent.projectBefore(DataChangeEvent dataChangeEvent, RecordData projectedBefore) Updates the before of a DataChangeEvent instance that describes the event with meta info.
static DataChangeEvent	DataChangeEvent.replaceEvent(TableId tableId, RecordData after) Creates a DataChangeEvent instance that describes the replace event.
static DataChangeEvent	DataChangeEvent.replaceEvent(TableId tableId, RecordData after, Map<String,String> meta) Creates a DataChangeEvent instance that describes the replace event with meta info.
static DataChangeEvent	DataChangeEvent.route(DataChangeEvent dataChangeEvent, TableId tableId) Updates the TableId info of current data change event.
static DataChangeEvent	DataChangeEvent.updateEvent(TableId tableId, RecordData before, RecordData after) Creates a DataChangeEvent instance that describes the update event.
static DataChangeEvent	DataChangeEvent.updateEvent(TableId tableId, RecordData before, RecordData after, Map<String,String> meta) Creates a DataChangeEvent instance that describes the update event with meta info.

参数类型为DataChangeEvent的org.apache.flink.cdc.common.event中的方法

限定符和类型	方法和说明
static DataChangeEvent	DataChangeEvent.projectAfter(DataChangeEvent dataChangeEvent, RecordData projectedAfter) Updates the after of a DataChangeEvent instance that describes the event with meta info.
static DataChangeEvent	DataChangeEvent.projectBefore(DataChangeEvent dataChangeEvent, RecordData projectedBefore) Updates the before of a DataChangeEvent instance that describes the event with meta info.
static DataChangeEvent	DataChangeEvent.route(DataChangeEvent dataChangeEvent, TableId tableId) Updates the TableId info of current data change event.

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

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

限定符和类型	方法和说明
default HashFunctionProvider<DataChangeEvent>	DataSink.getDataChangeEventHashFunctionProvider() Get the HashFunctionProvider<DataChangeEvent> for calculating hash value if you need to partition by data change event before Sink.
default HashFunctionProvider<DataChangeEvent>	DataSink.getDataChangeEventHashFunctionProvider(int parallelism)
HashFunction<DataChangeEvent>	DefaultDataChangeEventHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)

org.apache.flink.cdc.common.utils中DataChangeEvent的使用

返回DataChangeEvent的org.apache.flink.cdc.common.utils中的方法

限定符和类型	方法和说明
static DataChangeEvent	ChangeEventUtils.recreateDataChangeEvent(DataChangeEvent dataChangeEvent, TableId tableId)

参数类型为DataChangeEvent的org.apache.flink.cdc.common.utils中的方法

限定符和类型	方法和说明
static DataChangeEvent	ChangeEventUtils.recreateDataChangeEvent(DataChangeEvent dataChangeEvent, TableId tableId)