org.apache.paimon.mergetree

Class LookupFile

java.lang.Object

org.apache.paimon.mergetree.LookupFile

public class LookupFile
extends Object

Lookup file for cache remote file to local.

Constructor Summary

Constructors

Constructor and Description
LookupFile(File localFile, DataFileMeta remoteFile, LookupStoreReader reader, Runnable callback)

Method Summary

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()

Methods inherited from class java.lang.Object

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

Constructor Detail

LookupFile

public LookupFile(File localFile,
                  DataFileMeta remoteFile,
                  LookupStoreReader reader,
                  Runnable callback)

Method Detail

get

@Nullable
public byte[] get(byte[] key)
                     throws IOException

Throws:

IOException

remoteFile

public DataFileMeta remoteFile()

isClosed

public boolean isClosed()

close

public void close(org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.RemovalCause cause)
           throws IOException

Throws:

IOException

createCache

public static org.apache.paimon.shade.caffeine2.com.github.benmanes.caffeine.cache.Cache<String,LookupFile> createCache(java.time.Duration fileRetention,
                                                                                                                        MemorySize maxDiskSize)

localFilePrefix

public static String localFilePrefix(RowType partitionType,
                                     BinaryRow partition,
                                     int bucket,
                                     String remoteFileName)