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.
CompactionDiffFollowUpScanner	FollowUpScanner for read all changed files after compact.
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.
IncrementalCompactDiffSplitRead	A SplitRead for streaming incremental diff after compaction.
LookupCompactDiffRead	An InnerTableRead that reads the data changed before and after compaction.
LookupDataTableScan	StreamTableScan implementation for lookup streaming planning.
LookupFileStoreTable	FileStoreTable for lookup table.
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-.
PartitionLoader	Specify partitions for lookup tables.
PrimaryKeyLookupTable	A LookupTable for primary key table.
PrimaryKeyPartialLookupTable	Lookup table for primary key which supports to read the LSM tree directly.
RefreshBlacklist	Refresh black list for FileStoreLookupFunction.
SecondaryIndexLookupTable	A LookupTable for primary key table which provides lookup by secondary key.
StaticPartitionLoader	PartitionLoader for specified static partitions.

Enum Summary

Enum	Description
LookupFileStoreTable.LookupStreamScanMode	Inner stream scan mode for lookup table.

Exception Summary

Exception	Description
ReopenException	Signals that dim table source need to reopen.