org.apache.paimon.table.sink

Interface KeyAndBucketExtractor<T>

Type Parameters:

T - type of record

All Known Implementing Classes:

CdcRecordKeyAndBucketExtractor, DynamicBucketRowKeyExtractor, FixedBucketFromPkExtractor, FixedBucketRowKeyExtractor, PostponeBucketRowKeyExtractor, RowDataKeyAndBucketExtractor, RowKeyExtractor, UnawareBucketRowKeyExtractor

public interface KeyAndBucketExtractor<T>

Utility interface to extract partition keys, bucket id, primary keys for file store (trimmedPrimaryKey) and primary keys for external log system (logPrimaryKey) from the given record.

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

Method Summary

Modifier and Type	Method and Description
int	bucket()
static int	bucket(int hashcode, int numBuckets)
static int	bucketKeyHashCode(BinaryRow bucketKey)
BinaryRow	logPrimaryKey()
BinaryRow	partition()
void	setRecord(T record)
BinaryRow	trimmedPrimaryKey()

Field Detail

LOG

static final org.slf4j.Logger LOG

Method Detail

setRecord

void setRecord(T record)

partition

BinaryRow partition()

bucket

int bucket()

trimmedPrimaryKey

BinaryRow trimmedPrimaryKey()

logPrimaryKey

BinaryRow logPrimaryKey()

bucketKeyHashCode

static int bucketKeyHashCode(BinaryRow bucketKey)

bucket

static int bucket(int hashcode,
                  int numBuckets)