Modifier and Type | Class and Description |
---|---|
class |
HBaseLookupFunction
The HBaseLookupFunction is a standard user-defined table function, it can be used in tableAPI and
also useful for temporal table join plan in SQL.
|
class |
HBaseRowDataLookupFunction
The HBaseRowDataLookupFunction is a standard user-defined table function, it can be used in
tableAPI and also useful for temporal table join plan in SQL.
|
Modifier and Type | Method and Description |
---|---|
TableFunction<Row> |
AbstractHBaseTableSource.getLookupFunction(String[] lookupKeys) |
Modifier and Type | Class and Description |
---|---|
class |
JdbcLookupFunction
A
TableFunction to query fields from JDBC by keys. |
class |
JdbcRowDataLookupFunction
A lookup function for
JdbcDynamicTableSource . |
Modifier and Type | Method and Description |
---|---|
TableFunction<Row> |
JdbcTableSource.getLookupFunction(String[] lookupKeys) |
Modifier and Type | Method and Description |
---|---|
<T> void |
BatchTableEnvironment.registerFunction(String name,
TableFunction<T> tableFunction)
Registers a
TableFunction under a unique name in the TableEnvironment's catalog. |
<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. |
Modifier and Type | Method and Description |
---|---|
<T> void |
StreamTableEnvironmentImpl.registerFunction(String name,
TableFunction<T> tableFunction) |
Modifier and Type | Method and Description |
---|---|
<T> void |
FunctionCatalog.registerTempSystemTableFunction(String name,
TableFunction<T> function,
TypeInformation<T> resultType)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
TableFunction<T> |
TableFunctionProvider.createTableFunction()
Creates a
TableFunction instance. |
Modifier and Type | Method and Description |
---|---|
static <T> TableFunctionProvider<T> |
TableFunctionProvider.of(TableFunction<T> tableFunction)
Helper method for creating a static provider.
|
Modifier and Type | Class and Description |
---|---|
class |
FileSystemLookupFunction<P>
Lookup function for filesystem connector tables.
|
Modifier and Type | Class and Description |
---|---|
class |
TemporalTableFunction
Class representing temporal table function over some history table.
|
class |
TemporalTableFunctionImpl
Class representing temporal table function over some history table.
|
Modifier and Type | Method and Description |
---|---|
TableFunction<?> |
TableFunctionDefinition.getTableFunction() |
Modifier and Type | Method and Description |
---|---|
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.
|
Constructor and Description |
---|
TableFunctionDefinition(String name,
TableFunction<?> tableFunction,
TypeInformation<?> resultType) |
Modifier and Type | Class and Description |
---|---|
class |
HiveGenericUDTF
A TableFunction implementation that calls Hive's
GenericUDTF . |
Modifier and Type | Class and Description |
---|---|
class |
PythonTableFunction
The wrapper of user defined python table function.
|
Modifier and Type | Class and Description |
---|---|
class |
ReplicateRows
Replicate the row N times.
|
Modifier and Type | Method and Description |
---|---|
TableFunction |
HiveTableSqlFunction.makeFunction(Object[] constantArguments,
LogicalType[] argTypes)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static HiveTableSqlFunction.HiveOperandTypeChecker |
HiveTableSqlFunction.operandTypeChecker(String name,
TableFunction udtf)
Deprecated.
|
Constructor and Description |
---|
HiveTableSqlFunction(FunctionIdentifier identifier,
TableFunction hiveUdtf,
DataType implicitResultType,
org.apache.flink.table.planner.calcite.FlinkTypeFactory typeFactory,
org.apache.flink.table.planner.plan.schema.FlinkTableFunction functionImpl,
HiveTableSqlFunction.HiveOperandTypeChecker operandTypeChecker)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
static class |
SqlUnnestUtils.CollectionUnnestTableFunction
Table function that unwraps the elements of a collection (array or multiset).
|
static class |
SqlUnnestUtils.MapUnnestTableFunction
Table function that unwraps the elements of a map.
|
static class |
SqlUnnestUtils.UnnestTableFunction
Base table function for all unnest functions.
|
Modifier and Type | Class and Description |
---|---|
static class |
CsvTableSource.CsvLookupFunction
LookupFunction to support lookup in CsvTableSource.
|
Modifier and Type | Method and Description |
---|---|
TableFunction<Row> |
CsvTableSource.getLookupFunction(String[] lookupKeys) |
TableFunction<T> |
LookupableTableSource.getLookupFunction(String[] lookupKeys)
Deprecated.
Gets the
TableFunction which supports lookup one key at a time. |
Modifier and Type | Method and Description |
---|---|
static TypeInference |
TypeInferenceExtractor.forTableFunction(DataTypeFactory typeFactory,
Class<? extends TableFunction<?>> function)
Extracts a type inference from a
TableFunction . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.