public class LookupLevels<T> extends Object implements Levels.DropFileCallback, Closeable
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
|
static interface |
LookupLevels.ValueProcessor<T>
Processor to process value.
|
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) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
Levels |
getLevels() |
T |
lookup(InternalRow key,
int startLevel) |
void |
notifyDropFile(String file) |
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)
public Levels getLevels()
public void notifyDropFile(String file)
notifyDropFile
in interface Levels.DropFileCallback
@Nullable public T lookup(InternalRow key, int startLevel) throws IOException
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.