org.apache.paimon.index

Class SimpleHashBucketAssigner

java.lang.Object

org.apache.paimon.index.SimpleHashBucketAssigner

All Implemented Interfaces:

BucketAssigner

public class SimpleHashBucketAssigner
extends Object
implements BucketAssigner

When we need to overwrite the table, we should use this to avoid loading index.

Constructor Summary

Constructors

Constructor and Description
SimpleHashBucketAssigner(int numAssigners, int assignId, long targetBucketRowNumber, int maxBucketsNum)

Method Summary

Modifier and Type	Method and Description
int	assign(BinaryRow partition, int hash)
void	prepareCommit(long commitIdentifier)

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

SimpleHashBucketAssigner

public SimpleHashBucketAssigner(int numAssigners,
                                int assignId,
                                long targetBucketRowNumber,
                                int maxBucketsNum)

Method Detail

assign

public int assign(BinaryRow partition,
                  int hash)

Specified by:

assign in interface BucketAssigner

prepareCommit

public void prepareCommit(long commitIdentifier)

Specified by:

prepareCommit in interface BucketAssigner