org.apache.paimon.mergetree

Class LookupLevels<T>

java.lang.Object

org.apache.paimon.mergetree.LookupLevels<T>

All Implemented Interfaces:

Closeable, AutoCloseable, Levels.DropFileCallback

public class LookupLevels<T>
extends Object
implements Levels.DropFileCallback, Closeable

Provide lookup by key.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LookupLevels.ContainsValueProcessor A LookupLevels.ValueProcessor to return Boolean only.
static class	LookupLevels.KeyValueProcessor A LookupLevels.ValueProcessor to return KeyValue.
static class	LookupLevels.PositionedKeyValue KeyValue with file name and row position for DeletionVector.
static class	LookupLevels.PositionedKeyValueProcessor A LookupLevels.ValueProcessor to return LookupLevels.PositionedKeyValue.
static interface	LookupLevels.ValueProcessor<T> Processor to process value.

Constructor Summary

Constructors

Constructor and Description

LookupLevels(Levels levels, Comparator<InternalRow> keyComparator, RowType keyType, LookupLevels.ValueProcessor<T> valueProcessor, IOFunction<DataFileMeta,RecordReader<KeyValue>> fileReaderFactory, java.util.function.Function<String,File> localFileFactory, LookupStoreFactory lookupStoreFactory, java.util.function.Function<Long,BloomFilter.Builder> bfGenerator, org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.Cache<String,LookupFile> lookupFileCache)

Method Summary

Modifier and Type	Method and Description
void	close()
Levels	getLevels()
T	lookup(InternalRow key, int startLevel)
void	notifyDropFile(String file)

Methods inherited from class java.lang.Object

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

Constructor Detail

LookupLevels

public LookupLevels(Levels levels,
                    Comparator<InternalRow> keyComparator,
                    RowType keyType,
                    LookupLevels.ValueProcessor<T> valueProcessor,
                    IOFunction<DataFileMeta,RecordReader<KeyValue>> fileReaderFactory,
                    java.util.function.Function<String,File> localFileFactory,
                    LookupStoreFactory lookupStoreFactory,
                    java.util.function.Function<Long,BloomFilter.Builder> bfGenerator,
                    org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.Cache<String,LookupFile> lookupFileCache)

Method Detail

getLevels

public Levels getLevels()

notifyDropFile

public void notifyDropFile(String file)

Specified by:

notifyDropFile in interface Levels.DropFileCallback

lookup

@Nullable
public T lookup(InternalRow key,
                          int startLevel)
                   throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException