org.apache.paimon.table.sink

Interface PartitionKeyExtractor<T>

All Known Implementing Classes:

CdcRecordPartitionKeyExtractor, KeyPartPartitionKeyExtractor, RowPartitionKeyExtractor

public interface PartitionKeyExtractor<T>

Extractor to extract partition and trimmed primary key.

Method Summary

Modifier and Type	Method and Description
BinaryRow	partition(T record)
BinaryRow	trimmedPrimaryKey(T record)

Method Detail

partition

BinaryRow partition(T record)

trimmedPrimaryKey

BinaryRow trimmedPrimaryKey(T record)