| 程序包 | 说明 |
|---|---|
| org.apache.flink.cdc.common.data | |
| org.apache.flink.cdc.common.utils |
| 限定符和类型 | 方法和说明 |
|---|---|
static RecordData.FieldGetter |
RecordData.createFieldGetter(DataType fieldType,
int fieldPos)
Creates an accessor for getting elements in an internal RecordData structure at the given
position.
|
| 限定符和类型 | 方法和说明 |
|---|---|
static List<RecordData.FieldGetter> |
SchemaUtils.createFieldGetters(List<Column> columns)
create a list of
RecordData.FieldGetter from given Column to get Object from
RecordData. |
static List<RecordData.FieldGetter> |
SchemaUtils.createFieldGetters(Schema schema)
create a list of
RecordData.FieldGetter from given Schema to get Object from
RecordData. |
| 限定符和类型 | 方法和说明 |
|---|---|
static List<Object> |
SchemaUtils.restoreOriginalData(RecordData recordData,
List<RecordData.FieldGetter> fieldGetters)
Restore original data fields from RecordData structure.
|
Copyright © 2025 The Apache Software Foundation. All rights reserved.