org.apache.paimon.table

Class PrimaryKeyTableUtils

java.lang.Object

org.apache.paimon.table.PrimaryKeyTableUtils

public class PrimaryKeyTableUtils
extends Object

Utils for creating changelog table with primary keys.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PrimaryKeyTableUtils.PrimaryKeyFieldsExtractor Primary key fields extractor.

Constructor Summary

Constructors

Constructor and Description
PrimaryKeyTableUtils()

Method Summary

Modifier and Type	Method and Description
static List<DataField>	addKeyNamePrefix(List<DataField> keyFields)
static RowType	addKeyNamePrefix(RowType type)
static MergeFunctionFactory<KeyValue>	createMergeFunctionFactory(TableSchema tableSchema, KeyValueFieldsExtractor extractor)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PrimaryKeyTableUtils

public PrimaryKeyTableUtils()

Method Detail

addKeyNamePrefix

public static RowType addKeyNamePrefix(RowType type)

addKeyNamePrefix

public static List<DataField> addKeyNamePrefix(List<DataField> keyFields)

createMergeFunctionFactory

public static MergeFunctionFactory<KeyValue> createMergeFunctionFactory(TableSchema tableSchema,
                                                                        KeyValueFieldsExtractor extractor)