public class FileSystemLookupFunction<T extends InputSplit> extends TableFunction<RowData>
Constructor and Description |
---|
FileSystemLookupFunction(InputFormat<RowData,T> inputFormat,
String[] lookupKeys,
String[] producedNames,
DataType[] producedTypes,
java.time.Duration cacheTTL) |
Modifier and Type | Method and Description |
---|---|
void |
eval(Object... values) |
java.time.Duration |
getCacheTTL() |
TypeInformation<RowData> |
getResultType()
Returns the result type of the evaluation method.
|
void |
open(FunctionContext context)
Setup method for user-defined function.
|
collect, getKind, getParameterTypes, getTypeInference, setCollector
close, functionIdentifier, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getRequirements, isDeterministic
public TypeInformation<RowData> getResultType()
TableFunction
getResultType
in class TableFunction<RowData>
public void open(FunctionContext context) throws Exception
UserDefinedFunction
open
in class UserDefinedFunction
Exception
public void eval(Object... values)
@VisibleForTesting public java.time.Duration getCacheTTL()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.