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

public static class CsvTableSource.CsvLookupFunction
extends TableFunction<Row>

LookupFunction to support lookup in CsvTableSource.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.table.functions.TableFunction

collector

Method Summary

Modifier and Type	Method and 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 with a given signature.
void	open(FunctionContext context) Setup method for user-defined function.

Methods inherited from class org.apache.flink.table.functions.TableFunction

collect, getKind, getParameterTypes, 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

Method Detail

getResultType

public TypeInformation<Row> getResultType()

Description copied from class: TableFunction

Returns the result type of the evaluation method with a given signature.

This method needs to be overridden in case Flink's type extraction facilities are not sufficient to extract the TypeInformation based on the return type of the evaluation method. Flink's type extraction facilities can handle basic types or simple POJOs but might be wrong for more complex, custom, or composite types.

Overrides:

getResultType in class TableFunction<Row>

Returns:

TypeInformation of result type or null if Flink should determine the type

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 class UserDefinedFunction

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 class UserDefinedFunction

Throws:

Exception