Uses of Class
org.apache.flink.table.functions.TableFunction

Packages that use TableFunction

Package	Description
org.apache.flink.connectors.hive
org.apache.flink.table.api.bridge.java
org.apache.flink.table.api.bridge.java.internal
org.apache.flink.table.catalog
org.apache.flink.table.connector.source
org.apache.flink.table.functions
org.apache.flink.table.functions.hive
org.apache.flink.table.functions.python
org.apache.flink.table.planner.plan.nodes.exec.batch
org.apache.flink.table.planner.plan.nodes.exec.common
org.apache.flink.table.planner.plan.nodes.exec.stream
org.apache.flink.table.runtime.functions.table
org.apache.flink.table.runtime.functions.table.lookup
org.apache.flink.table.runtime.operators.join.lookup
org.apache.flink.table.sources
org.apache.flink.table.types.extraction

Uses of TableFunction in org.apache.flink.connectors.hive

Subclasses of TableFunction in org.apache.flink.connectors.hive

Modifier and Type	Class and Description
class	FileSystemLookupFunction<P> Lookup function for filesystem connector tables.

Uses of TableFunction in org.apache.flink.table.api.bridge.java

Methods in org.apache.flink.table.api.bridge.java with parameters of type TableFunction

Modifier and Type

Method and Description

<T> void

StreamTableEnvironment.registerFunction(String name, TableFunction<T> tableFunction) Deprecated. Use TableEnvironment.createTemporarySystemFunction(String, UserDefinedFunction) instead. Please note that the new method also uses the new type system and reflective extraction logic. It might be necessary to update the function implementation as well. See the documentation of TableFunction for more information on the new function design.

Uses of TableFunction in org.apache.flink.table.api.bridge.java.internal

Methods in org.apache.flink.table.api.bridge.java.internal with parameters of type TableFunction

Modifier and Type	Method and Description
<T> void	StreamTableEnvironmentImpl.registerFunction(String name, TableFunction<T> tableFunction)

Uses of TableFunction in org.apache.flink.table.catalog

Methods in org.apache.flink.table.catalog with parameters of type TableFunction

Modifier and Type	Method and Description
<T> void	FunctionCatalog.registerTempSystemTableFunction(String name, TableFunction<T> function, TypeInformation<T> resultType) Deprecated. Use FunctionCatalog.registerTemporarySystemFunction(String, FunctionDefinition, boolean) instead.

Uses of TableFunction in org.apache.flink.table.connector.source

Methods in org.apache.flink.table.connector.source that return TableFunction

Modifier and Type	Method and Description
TableFunction<T>	TableFunctionProvider.createTableFunction() Deprecated. Creates a TableFunction instance.

Methods in org.apache.flink.table.connector.source with parameters of type TableFunction

Modifier and Type	Method and Description
static <T> TableFunctionProvider<T>	TableFunctionProvider.of(TableFunction<T> tableFunction) Deprecated. Helper method for creating a static provider.

Uses of TableFunction in org.apache.flink.table.functions

Subclasses of TableFunction in org.apache.flink.table.functions

Modifier and Type	Class and Description
class	LookupFunction A wrapper class of TableFunction for synchronously lookup rows matching the lookup keys from external system.
class	TemporalTableFunction Class representing temporal table function over some history table.
class	TemporalTableFunctionImpl Class representing temporal table function over some history table.

Methods in org.apache.flink.table.functions that return TableFunction

Modifier and Type	Method and Description
TableFunction<?>	TableFunctionDefinition.getTableFunction() Deprecated.

Methods in org.apache.flink.table.functions with parameters of type TableFunction

Modifier and Type	Method and Description
static InputTypeStrategy	LegacyUserDefinedFunctionInference.getInputTypeStrategy(TableFunction<?> func) Deprecated.
static <T> TypeInformation<T>	UserDefinedFunctionHelper.getReturnTypeOfTableFunction(TableFunction<T> tableFunction) Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
static <T> TypeInformation<T>	UserDefinedFunctionHelper.getReturnTypeOfTableFunction(TableFunction<T> tableFunction, TypeInformation<T> scalaType) Tries to infer the TypeInformation of an AggregateFunction's accumulator type.

Constructors in org.apache.flink.table.functions with parameters of type TableFunction

Constructor and Description
TableFunctionDefinition(String name, TableFunction<?> tableFunction, TypeInformation<?> resultType) Deprecated.

Uses of TableFunction in org.apache.flink.table.functions.hive

Subclasses of TableFunction in org.apache.flink.table.functions.hive

Modifier and Type	Class and Description
class	HiveGenericUDTF A TableFunction implementation that calls Hive's GenericUDTF.

Uses of TableFunction in org.apache.flink.table.functions.python

Subclasses of TableFunction in org.apache.flink.table.functions.python

Modifier and Type	Class and Description
class	PythonTableFunction The wrapper of user defined python table function.

Uses of TableFunction in org.apache.flink.table.planner.plan.nodes.exec.batch

Methods in org.apache.flink.table.planner.plan.nodes.exec.batch with parameters of type TableFunction

Modifier and Type

Method and Description

protected Transformation<RowData>

BatchExecLookupJoin.createSyncLookupJoinWithState(Transformation<RowData> inputTransformation, org.apache.calcite.plan.RelOptTable temporalTable, ExecNodeConfig config, ClassLoader classLoader, Map<Integer,LookupJoinUtil.LookupKey> allLookupKeys, TableFunction<?> syncLookupFunction, RelBuilder relBuilder, RowType inputRowType, RowType tableSourceRowType, RowType resultRowType, boolean isLeftOuterJoin, boolean isObjectReuseEnabled, boolean lookupKeyContainsPrimaryKey)

Uses of TableFunction in org.apache.flink.table.planner.plan.nodes.exec.common

Methods in org.apache.flink.table.planner.plan.nodes.exec.common with parameters of type TableFunction

Modifier and Type	Method and Description
protected ProcessFunction<RowData,RowData>	CommonExecLookupJoin.createSyncLookupJoinFunction(org.apache.calcite.plan.RelOptTable temporalTable, ExecNodeConfig config, ClassLoader classLoader, Map<Integer,LookupJoinUtil.LookupKey> allLookupKeys, TableFunction<?> syncLookupFunction, RelBuilder relBuilder, RowType inputRowType, RowType tableSourceRowType, RowType resultRowType, boolean isLeftOuterJoin, boolean isObjectReuseEnabled)
protected abstract Transformation<RowData>	CommonExecLookupJoin.createSyncLookupJoinWithState(Transformation<RowData> inputTransformation, org.apache.calcite.plan.RelOptTable temporalTable, ExecNodeConfig config, ClassLoader classLoader, Map<Integer,LookupJoinUtil.LookupKey> allLookupKeys, TableFunction<?> syncLookupFunction, RelBuilder relBuilder, RowType inputRowType, RowType tableSourceRowType, RowType resultRowType, boolean isLeftOuterJoin, boolean isObjectReuseEnabled, boolean lookupKeyContainsPrimaryKey)

Uses of TableFunction in org.apache.flink.table.planner.plan.nodes.exec.stream

Methods in org.apache.flink.table.planner.plan.nodes.exec.stream with parameters of type TableFunction

Modifier and Type

Method and Description

protected Transformation<RowData>

StreamExecLookupJoin.createSyncLookupJoinWithState(Transformation<RowData> inputTransformation, org.apache.calcite.plan.RelOptTable temporalTable, ExecNodeConfig config, ClassLoader classLoader, Map<Integer,LookupJoinUtil.LookupKey> allLookupKeys, TableFunction<?> syncLookupFunction, RelBuilder relBuilder, RowType inputRowType, RowType tableSourceRowType, RowType resultRowType, boolean isLeftOuterJoin, boolean isObjectReuseEnabled, boolean lookupKeyContainsPrimaryKey)

Uses of TableFunction in org.apache.flink.table.runtime.functions.table

Subclasses of TableFunction in org.apache.flink.table.runtime.functions.table

Modifier and Type	Class and Description
class	BuiltInTableFunction<T> Base class for runtime implementation represented as TableFunction that is constructed from SpecializedFunction.specialize(SpecializedContext).
class	ReplicateRowsFunction Replicate the row N times.
static class	UnnestRowsFunction.CollectionUnnestTableFunction Table function that unwraps the elements of a collection (array or multiset).
static class	UnnestRowsFunction.MapUnnestTableFunction Table function that unwraps the elements of a map.

Uses of TableFunction in org.apache.flink.table.runtime.functions.table.lookup

Subclasses of TableFunction in org.apache.flink.table.runtime.functions.table.lookup

Modifier and Type	Class and Description
class	CachingLookupFunction A wrapper function around user-provided lookup function with a cache layer.

Uses of TableFunction in org.apache.flink.table.runtime.operators.join.lookup

Subclasses of TableFunction in org.apache.flink.table.runtime.operators.join.lookup

Modifier and Type	Class and Description
class	RetryableLookupFunctionDelegator A delegator holds user's LookupFunction to handle retries.

Uses of TableFunction in org.apache.flink.table.sources

Subclasses of TableFunction in org.apache.flink.table.sources

Modifier and Type	Class and Description
static class	CsvTableSource.CsvLookupFunction Deprecated. LookupFunction to support lookup in CsvTableSource.

Methods in org.apache.flink.table.sources that return TableFunction

Modifier and Type	Method and Description
TableFunction<Row>	CsvTableSource.getLookupFunction(String[] lookupKeys) Deprecated.
TableFunction<T>	LookupableTableSource.getLookupFunction(String[] lookupKeys) Deprecated. Gets the TableFunction which supports lookup one key at a time.

Uses of TableFunction in org.apache.flink.table.types.extraction

Method parameters in org.apache.flink.table.types.extraction with type arguments of type TableFunction

Modifier and Type	Method and Description
static TypeInference	TypeInferenceExtractor.forTableFunction(DataTypeFactory typeFactory, Class<? extends TableFunction<?>> function) Extracts a type inference from a TableFunction.