org.apache.paimon.index

Interface BucketAssigner

All Known Implementing Classes:

HashBucketAssigner, SimpleHashBucketAssigner

public interface BucketAssigner

Assigner a bucket for a record, just used in dynamic bucket table.

Method Summary

Modifier and Type	Method and Description
int	assign(BinaryRow partition, int hash)
static int	computeAssigner(int partitionHash, int keyHash, int numChannels, int numAssigners)
static int	computeHashKey(int partitionHash, int keyHash, int numChannels, int numAssigners)
static boolean	isMyBucket(int bucket, int numAssigners, int assignId)
void	prepareCommit(long commitIdentifier)

Method Detail

assign

int assign(BinaryRow partition,
           int hash)

prepareCommit

void prepareCommit(long commitIdentifier)

isMyBucket

static boolean isMyBucket(int bucket,
                          int numAssigners,
                          int assignId)

computeHashKey

static int computeHashKey(int partitionHash,
                          int keyHash,
                          int numChannels,
                          int numAssigners)

computeAssigner

static int computeAssigner(int partitionHash,
                           int keyHash,
                           int numChannels,
                           int numAssigners)