org.apache.paimon.flink.lookup

Interface LookupTable

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

FullCacheLookupTable, NoPrimaryKeyLookupTable, PrimaryKeyLookupTable, PrimaryKeyPartialLookupTable, SecondaryIndexLookupTable

public interface LookupTable
extends Closeable

A lookup table which provides get and refresh.

Method Summary

Modifier and Type	Method and Description
List<InternalRow>	get(InternalRow key)
void	open()
void	refresh()
void	specificPartitionFilter(Predicate filter)
void	specifyCacheRowFilter(Filter<InternalRow> filter)

Methods inherited from interface java.io.Closeable

close

Method Detail

specificPartitionFilter

void specificPartitionFilter(Predicate filter)

open

void open()
   throws Exception

Throws:

Exception

get

List<InternalRow> get(InternalRow key)
               throws IOException

Throws:

IOException

refresh

void refresh()
      throws Exception

Throws:

Exception

specifyCacheRowFilter

void specifyCacheRowFilter(Filter<InternalRow> filter)