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–2024 The Apache Software Foundation. All rights reserved.