org.apache.paimon.index

Class PartitionIndex

java.lang.Object

org.apache.paimon.index.PartitionIndex

public class PartitionIndex
extends Object

Bucket Index Per Partition.

Field Summary

Fields

Modifier and Type	Field and Description
boolean	accessed
Int2ShortHashMap	hash2Bucket
long	lastAccessedCommitIdentifier
Map<Integer,Long>	nonFullBucketInformation
Set<Integer>	totalBucket

Constructor Summary

Constructors

Constructor and Description
PartitionIndex(Int2ShortHashMap hash2Bucket, Map<Integer,Long> bucketInformation, long targetBucketRowNumber)

Method Summary

Modifier and Type	Method and Description
int	assign(int hash, java.util.function.IntPredicate bucketFilter)
static PartitionIndex	loadIndex(IndexFileHandler indexFileHandler, BinaryRow partition, long targetBucketRowNumber, java.util.function.IntPredicate loadFilter, java.util.function.IntPredicate bucketFilter)

Methods inherited from class java.lang.Object

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

Field Detail

hash2Bucket

public final Int2ShortHashMap hash2Bucket

nonFullBucketInformation

public final Map<Integer,Long> nonFullBucketInformation

totalBucket

public final Set<Integer> totalBucket

accessed

public boolean accessed

lastAccessedCommitIdentifier

public long lastAccessedCommitIdentifier

Constructor Detail

PartitionIndex

public PartitionIndex(Int2ShortHashMap hash2Bucket,
                      Map<Integer,Long> bucketInformation,
                      long targetBucketRowNumber)

Method Detail

assign

public int assign(int hash,
                  java.util.function.IntPredicate bucketFilter)

loadIndex

public static PartitionIndex loadIndex(IndexFileHandler indexFileHandler,
                                       BinaryRow partition,
                                       long targetBucketRowNumber,
                                       java.util.function.IntPredicate loadFilter,
                                       java.util.function.IntPredicate bucketFilter)