org.apache.paimon.flink.lookup.partitioner

Class BucketIdExtractor

java.lang.Object

org.apache.paimon.flink.lookup.partitioner.BucketIdExtractor

All Implemented Interfaces:

Serializable

public class BucketIdExtractor
extends Object
implements Serializable

BucketIdExtractor is used to extract the bucket id from join keys. It requires that the join keys contain all bucket keys and projects the bucket key fields from the given join key row.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BucketIdExtractor(int numBuckets, TableSchema tableSchema, List<String> joinKeyFieldNames, List<String> bucketKeyFieldNames)

Method Summary

Modifier and Type	Method and Description
int	extractBucketId(org.apache.flink.table.data.RowData joinKeyRow)

Methods inherited from class java.lang.Object

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

Constructor Detail

BucketIdExtractor

public BucketIdExtractor(int numBuckets,
                         TableSchema tableSchema,
                         List<String> joinKeyFieldNames,
                         List<String> bucketKeyFieldNames)

Method Detail

extractBucketId

public int extractBucketId(org.apache.flink.table.data.RowData joinKeyRow)