Package org.apache.flink.table.sources
Class CsvTableSource.CsvLookupFunction
- java.lang.Object
-
- org.apache.flink.table.functions.UserDefinedFunction
-
- org.apache.flink.table.functions.TableFunction<Row>
-
- org.apache.flink.table.sources.CsvTableSource.CsvLookupFunction
-
- All Implemented Interfaces:
Serializable
,FunctionDefinition
- Enclosing class:
- CsvTableSource
@Internal public static class CsvTableSource.CsvLookupFunction extends TableFunction<Row>
LookupFunction to support lookup in CsvTableSource.- See Also:
- Serialized Form
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
Tear-down method for user-defined function.void
eval(Object... values)
TypeInformation<Row>
getResultType()
Returns the result type of the evaluation method.void
open(FunctionContext context)
Setup method for user-defined function.-
Methods inherited from class org.apache.flink.table.functions.TableFunction
collect, finish, getKind, getParameterTypes, getTypeInference, setCollector
-
Methods inherited from class org.apache.flink.table.functions.UserDefinedFunction
functionIdentifier, toString
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.flink.table.functions.FunctionDefinition
getRequirements, isDeterministic, supportsConstantFolding
-
-
-
-
Method Detail
-
getResultType
public TypeInformation<Row> getResultType()
Description copied from class:TableFunction
Returns the result type of the evaluation method.- Overrides:
getResultType
in classTableFunction<Row>
-
open
public void open(FunctionContext context) throws Exception
Description copied from class:UserDefinedFunction
Setup method for user-defined function. It can be used for initialization work. By default, this method does nothing.- Overrides:
open
in classUserDefinedFunction
- Throws:
Exception
-
eval
public void eval(Object... values)
-
close
public void close() throws Exception
Description copied from class:UserDefinedFunction
Tear-down method for user-defined function. It can be used for clean up work. By default, this method does nothing.- Overrides:
close
in classUserDefinedFunction
- Throws:
Exception
-
-