org.apache.paimon.flink.lookup

Class PrimaryKeyPartialLookupTable

java.lang.Object

org.apache.paimon.flink.lookup.PrimaryKeyPartialLookupTable

All Implemented Interfaces:

Closeable, AutoCloseable, LookupTable

public class PrimaryKeyPartialLookupTable
extends Object
implements LookupTable

Lookup table for primary key which supports to read the LSM tree directly.

Method Summary

Modifier and Type	Method and Description
void	close()
static PrimaryKeyPartialLookupTable	createLocalTable(FileStoreTable table, int[] projection, File tempPath, List<String> joinKey, Set<Integer> requireCachedBucketIds)
static PrimaryKeyPartialLookupTable	createRemoteTable(FileStoreTable table, int[] projection, List<String> joinKey)
List<InternalRow>	get(InternalRow key)
void	open()
void	refresh()
void	specificPartitionFilter(Predicate filter)
void	specifyCacheRowFilter(Filter<InternalRow> filter)

Methods inherited from class java.lang.Object

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

Method Detail

specificPartitionFilter

public void specificPartitionFilter(Predicate filter)

Specified by:

specificPartitionFilter in interface LookupTable

open

public void open()
          throws Exception

Specified by:

open in interface LookupTable

Throws:

Exception

get

public List<InternalRow> get(InternalRow key)
                      throws IOException

Specified by:

get in interface LookupTable

Throws:

IOException

refresh

public void refresh()

Specified by:

refresh in interface LookupTable

specifyCacheRowFilter

public void specifyCacheRowFilter(Filter<InternalRow> filter)

Specified by:

specifyCacheRowFilter in interface LookupTable

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

createLocalTable

public static PrimaryKeyPartialLookupTable createLocalTable(FileStoreTable table,
                                                            int[] projection,
                                                            File tempPath,
                                                            List<String> joinKey,
                                                            Set<Integer> requireCachedBucketIds)

createRemoteTable

public static PrimaryKeyPartialLookupTable createRemoteTable(FileStoreTable table,
                                                             int[] projection,
                                                             List<String> joinKey)