org.apache.paimon.flink.lookup

Class FixedBucketFromPkExtractor

java.lang.Object

org.apache.paimon.flink.lookup.FixedBucketFromPkExtractor

All Implemented Interfaces:

KeyAndBucketExtractor<InternalRow>

public class FixedBucketFromPkExtractor
extends Object
implements KeyAndBucketExtractor<InternalRow>

Extractor to extract bucket from the primary key.

Constructor Summary

Constructors

Constructor and Description
FixedBucketFromPkExtractor(TableSchema schema)

Method Summary

Modifier and Type	Method and Description
int	bucket()
BinaryRow	logPrimaryKey()
BinaryRow	partition()
void	setRecord(InternalRow record)
BinaryRow	trimmedPrimaryKey()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.table.sink.KeyAndBucketExtractor

bucket, bucketKeyHashCode

Constructor Detail

FixedBucketFromPkExtractor

public FixedBucketFromPkExtractor(TableSchema schema)

Method Detail

setRecord

public void setRecord(InternalRow record)

Specified by:

setRecord in interface KeyAndBucketExtractor<InternalRow>

partition

public BinaryRow partition()

Specified by:

partition in interface KeyAndBucketExtractor<InternalRow>

bucket

public int bucket()

Specified by:

bucket in interface KeyAndBucketExtractor<InternalRow>

trimmedPrimaryKey

public BinaryRow trimmedPrimaryKey()

Specified by:

trimmedPrimaryKey in interface KeyAndBucketExtractor<InternalRow>

logPrimaryKey

public BinaryRow logPrimaryKey()

Specified by:

logPrimaryKey in interface KeyAndBucketExtractor<InternalRow>