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.
|
Modifier and Type | Method and Description |
---|---|
TableFunction<Row> |
HBaseTableSource.getLookupFunction(String[] lookupKeys) |
Modifier and Type | Class and Description |
---|---|
class |
JDBCLookupFunction
A
TableFunction to query fields from JDBC by keys. |
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)
Registers a
TableFunction under a unique name in the TableEnvironment's catalog. |
Modifier and Type | Method and Description |
---|---|
<T> void |
StreamTableEnvironmentImpl.registerFunction(String name,
TableFunction<T> tableFunction) |
Modifier and Type | Method and Description |
---|---|
<T> void |
FunctionCatalog.registerTempCatalogTableFunction(ObjectIdentifier oi,
TableFunction<T> function,
TypeInformation<T> resultType) |
<T> void |
FunctionCatalog.registerTempSystemTableFunction(String name,
TableFunction<T> function,
TypeInformation<T> resultType) |
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 | Method and Description |
---|---|
TableFunction<T> |
CalculatedQueryOperation.getTableFunction() |
Constructor and Description |
---|
CalculatedQueryOperation(TableFunction<T> tableFunction,
List<ResolvedExpression> parameters,
TypeInformation<T> resultType,
TableSchema tableSchema) |
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 |
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)
Gets the
TableFunction which supports lookup one key at a time. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.