Package org.apache.paimon.flink.lookup

Interface Summary

Interface	Description
FullCacheLookupTable.TableBulkLoader	Bulk loader for the table.
LookupTable	A lookup table which provides get and refresh.

Class Summary

Class	Description
AsyncLookupFunctionWrapper	A AsyncLookupFunction to wrap sync function.
DynamicPartitionLoader	Dynamic partition for lookup.
FileStoreLookupFunction	A lookup TableFunction for file store.
FixedBucketFromPkExtractor	Extractor to extract bucket from the primary key.
FullCacheLookupTable	Lookup table of full cache.
FullCacheLookupTable.Context	Context for LookupTable.
LookupRuntimeProviderFactory	Factory to create LookupTableSource.LookupRuntimeProvider.
LookupStreamingReader	A streaming reader to load data into LookupTable.
NewLookupFunction	New LookupFunction for 1.16+, it supports Flink retry join.
NoPrimaryKeyLookupTable	A LookupTable for table without primary key.
OldLookupFunction	Old lookup TableFunction for 1.15-.
PrimaryKeyLookupTable	A LookupTable for primary key table.
PrimaryKeyPartialLookupTable	Lookup table for primary key which supports to read the LSM tree directly.
SecondaryIndexLookupTable	A LookupTable for primary key table which provides lookup by secondary key.