Package org.apache.paimon.flink.lookup.partitioner

Interface Summary

Interface	Description
ShuffleStrategy	Shuffle strategy use to assign bucket to subtask and get all the required buckets for a given task.

Class Summary

Class	Description
BucketIdExtractor	BucketIdExtractor is used to extract the bucket id from join keys.
BucketShufflePartitioner	BucketShufflePartitioner class partitions rows based on the bucket id.
BucketShuffleStrategy	BucketShuffleStrategy defines a strategy for determining the target subtask id for a given bucket id and join key hash.