public class FileStoreLookupFunction
extends org.apache.flink.table.functions.TableFunction<org.apache.flink.table.data.RowData>
TableFunction
for file store.Constructor and Description |
---|
FileStoreLookupFunction(FileStoreTable table,
int[] projection,
int[] joinKeyIndex,
Predicate predicate) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
eval(Object... values)
Used by code generation.
|
void |
open(org.apache.flink.table.functions.FunctionContext context) |
collect, getKind, getParameterTypes, getResultType, getTypeInference, setCollector
functionIdentifier, toString
public FileStoreLookupFunction(FileStoreTable table, int[] projection, int[] joinKeyIndex, @Nullable Predicate predicate)
public void open(org.apache.flink.table.functions.FunctionContext context) throws Exception
open
in class org.apache.flink.table.functions.UserDefinedFunction
Exception
public void close() throws IOException
close
in class org.apache.flink.table.functions.UserDefinedFunction
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.