接口的使用
org.apache.flink.cdc.common.data.RecordData

使用RecordData的程序包

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

org.apache.flink.cdc.common.data中RecordData的使用

返回RecordData的org.apache.flink.cdc.common.data中的方法

限定符和类型	方法和说明
RecordData	GenericArrayData.getRecord(int pos, int numFields)
RecordData	ArrayData.getRecord(int pos, int numFields) Returns the record value at the given position.
RecordData	RecordData.getRow(int pos, int numFields) Returns the row value at the given position.

参数类型为RecordData的org.apache.flink.cdc.common.data中的方法

限定符和类型	方法和说明
Object	RecordData.FieldGetter.getFieldOrNull(RecordData recordData)

org.apache.flink.cdc.common.data.binary中RecordData的使用

实现RecordData的org.apache.flink.cdc.common.data.binary中的类

限定符和类型	类和说明
class	BinaryRecordData An implementation of RecordData which is backed by MemorySegment instead of Object.

返回RecordData的org.apache.flink.cdc.common.data.binary中的方法

限定符和类型	方法和说明
RecordData	BinaryArrayData.getRecord(int pos, int numFields)
RecordData	BinaryRecordData.getRow(int pos, int numFields)
static RecordData	BinarySegmentUtils.readRecordData(org.apache.flink.core.memory.MemorySegment[] segments, int numFields, int baseOffset, long offsetAndSize) Gets an instance of RecordData from underlying MemorySegment.

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

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

限定符和类型	方法和说明
RecordData	DataChangeEvent.after()
RecordData	DataChangeEvent.before()

参数类型为RecordData的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.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.

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

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

限定符和类型	方法和说明
static List<Object>	SchemaUtils.restoreOriginalData(RecordData recordData, List<RecordData.FieldGetter> fieldGetters) Restore original data fields from RecordData structure.