| Package | Description |
|---|---|
| org.apache.paimon.flink.lookup | |
| org.apache.paimon.flink.source |
| Class and Description |
|---|
| DynamicPartitionLoader
Dynamic partition for lookup.
|
| FileStoreLookupFunction
A lookup
TableFunction for file store. |
| FullCacheLookupTable
Lookup table of full cache.
|
| FullCacheLookupTable.Context
Context for
LookupTable. |
| FullCacheLookupTable.TableBulkLoader
Bulk loader for the table.
|
LookupFileStoreTable
FileStoreTable for lookup table. |
| LookupFileStoreTable.LookupStreamScanMode
Inner stream scan mode for lookup table.
|
| LookupTable
A lookup table which provides get and refresh.
|
| NewLookupFunction
New
LookupFunction for 1.16+, it supports Flink retry join. |
| 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. |
| Class and Description |
|---|
| FileStoreLookupFunction
A lookup
TableFunction for file store. |
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.