org.apache.paimon.index

Class HashBucketAssigner

java.lang.Object

org.apache.paimon.index.HashBucketAssigner

All Implemented Interfaces:

BucketAssigner

public class HashBucketAssigner
extends Object
implements BucketAssigner

Assign bucket for key hashcode.

Constructor Summary

Constructors

Constructor and Description
HashBucketAssigner(SnapshotManager snapshotManager, String commitUser, IndexFileHandler indexFileHandler, int numChannels, int numAssigners, int assignId, long targetBucketRowNumber)

Method Summary

Modifier and Type	Method and Description
int	assign(BinaryRow partition, int hash) Assign a bucket for key hash of a record.
void	prepareCommit(long commitIdentifier) Prepare commit to clear outdated partition index.

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.index.BucketAssigner

computeAssigner, computeHashKey, isMyBucket

Constructor Detail

HashBucketAssigner

public HashBucketAssigner(SnapshotManager snapshotManager,
                          String commitUser,
                          IndexFileHandler indexFileHandler,
                          int numChannels,
                          int numAssigners,
                          int assignId,
                          long targetBucketRowNumber)

Method Detail

assign

public int assign(BinaryRow partition,
                  int hash)

Assign a bucket for key hash of a record.

Specified by:

assign in interface BucketAssigner

prepareCommit

public void prepareCommit(long commitIdentifier)

Prepare commit to clear outdated partition index.

Specified by:

prepareCommit in interface BucketAssigner