Package | Description |
---|---|
org.apache.paimon.data | |
org.apache.paimon.flink.sink.cdc | |
org.apache.paimon.utils |
Modifier and Type | Method and Description |
---|---|
static GenericRow |
GenericRow.of(Object... values)
Creates an instance of
GenericRow with given field values. |
static GenericRow |
GenericRow.ofKind(RowKind kind,
Object... values)
Creates an instance of
GenericRow with given kind and field values. |
Modifier and Type | Method and Description |
---|---|
static GenericRow |
CdcRecordUtils.projectAsInsert(CdcRecord record,
List<DataField> dataFields)
Project
fields to a GenericRow . |
Modifier and Type | Method and Description |
---|---|
static Optional<GenericRow> |
CdcRecordUtils.toGenericRow(CdcRecord record,
List<DataField> dataFields)
Convert
fields to a GenericRow . |
Modifier and Type | Method and Description |
---|---|
static CdcRecord |
CdcRecordUtils.fromGenericRow(GenericRow row,
List<String> fieldNames) |
Modifier and Type | Method and Description |
---|---|
GenericRow |
RowDataToObjectArrayConverter.toGenericRow(InternalRow rowData) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.