Package | Description |
---|---|
org.apache.paimon.flink.lookup | |
org.apache.paimon.flink.source |
Modifier and Type | Method and Description |
---|---|
static org.apache.flink.table.connector.source.LookupTableSource.LookupRuntimeProvider |
LookupRuntimeProviderFactory.create(FileStoreLookupFunction function,
boolean enableAsync,
int asyncThreadNumber) |
Constructor and Description |
---|
NewLookupFunction(FileStoreLookupFunction function) |
OldLookupFunction(FileStoreLookupFunction function) |
Modifier and Type | Method and Description |
---|---|
protected FileStoreLookupFunction |
BaseDataTableSource.getFileStoreLookupFunction(org.apache.flink.table.connector.source.LookupTableSource.LookupContext context,
Table table,
int[] projection,
int[] joinKey) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.