| Package | Description |
|---|---|
| org.apache.paimon.data | |
| org.apache.paimon.flink.sink.cdc | |
| org.apache.paimon.table.object | |
| 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,
boolean logCorruptRecord)
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 |
|---|---|
static GenericRow |
ObjectRefresh.toRow(Object... values) |
| Modifier and Type | Method and Description |
|---|---|
static GenericRow |
InternalRowPartitionComputer.convertSpecToInternalRow(Map<String,String> spec,
RowType partType,
String defaultPartValue) |
GenericRow |
RowDataToObjectArrayConverter.toGenericRow(InternalRow rowData) |
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.