org.apache.paimon.flink.lookup.partitioner

Interface ShuffleStrategy

All Superinterfaces:

Serializable

All Known Implementing Classes:

BucketShuffleStrategy

public interface ShuffleStrategy
extends Serializable

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

Method Summary

Modifier and Type	Method and Description
Set<Integer>	getRequiredCacheBucketIds(int subtaskId, int numSubtasks) Returns all the bucket IDs required for a given subtask.
int	getTargetSubtaskId(int bucketId, int joinKeyHash, int numSubtasks) Calculates and returns the subtask ID that a given bucket should be assigned to.

Method Detail

getTargetSubtaskId

int getTargetSubtaskId(int bucketId,
                       int joinKeyHash,
                       int numSubtasks)

Calculates and returns the subtask ID that a given bucket should be assigned to.

Parameters:

bucketId - The ID of the bucket.

joinKeyHash - The hash value of the join key.

numSubtasks - The total number of subtasks.

Returns:

The subtask ID that the bucket should be assigned to.

getRequiredCacheBucketIds

Set<Integer> getRequiredCacheBucketIds(int subtaskId,
                                       int numSubtasks)

Returns all the bucket IDs required for a given subtask.

Parameters:

subtaskId - The ID of the subtask.

numSubtasks - The total number of subtasks.

Returns:

A set containing all the bucket IDs required for the subtask.