public class LookupFile extends Object
Constructor and Description |
---|
LookupFile(File localFile,
DataFileMeta remoteFile,
LookupStoreReader reader,
Runnable callback) |
Modifier and Type | Method and Description |
---|---|
void |
close(org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.RemovalCause cause) |
static org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.Cache<String,LookupFile> |
createCache(java.time.Duration fileRetention,
MemorySize maxDiskSize) |
byte[] |
get(byte[] key) |
boolean |
isClosed() |
static String |
localFilePrefix(RowType partitionType,
BinaryRow partition,
int bucket,
String remoteFileName) |
DataFileMeta |
remoteFile() |
public LookupFile(File localFile, DataFileMeta remoteFile, LookupStoreReader reader, Runnable callback)
@Nullable public byte[] get(byte[] key) throws IOException
IOException
public DataFileMeta remoteFile()
public boolean isClosed()
public void close(org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.RemovalCause cause) throws IOException
IOException
public static org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.Cache<String,LookupFile> createCache(java.time.Duration fileRetention, MemorySize maxDiskSize)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.