org.apache.paimon.crosspartition

Class BucketAssigner

java.lang.Object

org.apache.paimon.crosspartition.BucketAssigner

public class BucketAssigner
extends Object

Bucket Assigner to assign bucket in a partition.

Constructor Summary

Constructors

Constructor and Description
BucketAssigner()

Method Summary

Modifier and Type	Method and Description
int	assignBucket(BinaryRow part, Filter<Integer> filter, int maxCount)
void	bootstrapBucket(BinaryRow part, int bucket)
void	decrement(BinaryRow part, int bucket)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BucketAssigner

public BucketAssigner()

Method Detail

bootstrapBucket

public void bootstrapBucket(BinaryRow part,
                            int bucket)

assignBucket

public int assignBucket(BinaryRow part,
                        Filter<Integer> filter,
                        int maxCount)

decrement

public void decrement(BinaryRow part,
                      int bucket)