Modifier and Type | Method and Description |
---|---|
<T> void |
TableEnvironment.registerTableFunctionInternal(String name,
TableFunction<T> function,
TypeInformation<T> evidence$1)
Registers a
TableFunction under a unique name. |
Modifier and Type | Method and Description |
---|---|
<T> void |
BatchTableEnvironment.registerFunction(String name,
TableFunction<T> tf)
Registers a
TableFunction under a unique name in the TableEnvironment's catalog. |
<T> void |
StreamTableEnvironment.registerFunction(String name,
TableFunction<T> tf)
Registers a
TableFunction under a unique name in the TableEnvironment's catalog. |
Modifier and Type | Method and Description |
---|---|
<T> void |
BatchTableEnvironment.registerFunction(String name,
TableFunction<T> tf,
TypeInformation<T> evidence$2)
Registers a
TableFunction under a unique name in the TableEnvironment's catalog. |
<T> void |
StreamTableEnvironment.registerFunction(String name,
TableFunction<T> tf,
TypeInformation<T> evidence$7)
Registers a
TableFunction under a unique name in the TableEnvironment's catalog. |
Constructor and Description |
---|
TableFunctionConversions(TableFunction<T> tf) |
Constructor and Description |
---|
TableFunctionCallGen(TableFunction<?> tableFunction,
scala.collection.Seq<TypeInformation<?>> signature,
TypeInformation<?> returnType) |
Constructor and Description |
---|
TableFunctionCall(String functionName,
TableFunction<?> tableFunction,
scala.collection.Seq<Expression> parameters,
TypeInformation<?> resultType) |
Modifier and Type | Method and Description |
---|---|
TableFunction<?> |
TableSqlFunction.getTableFunction()
Get the user-defined table function.
|
Modifier and Type | Method and Description |
---|---|
static TableSqlFunction |
TableSqlFunction.apply(String name,
TableFunction<?> udtf,
TypeInformation<?> rowTypeInfo,
FlinkTypeFactory typeFactory,
FlinkTableFunctionImpl<?> functionImpl)
Util function to create a
TableSqlFunction . |
TableSqlFunction |
TableSqlFunction$.apply(String name,
TableFunction<?> udtf,
TypeInformation<?> rowTypeInfo,
FlinkTypeFactory typeFactory,
FlinkTableFunctionImpl<?> functionImpl)
Util function to create a
TableSqlFunction . |
static scala.collection.Seq<org.apache.calcite.sql.SqlFunction> |
UserDefinedFunctionUtils.createTableSqlFunctions(String name,
TableFunction<?> tableFunction,
TypeInformation<?> resultType,
FlinkTypeFactory typeFactory)
Create
SqlFunction s for a TableFunction 's every eval method |
scala.collection.Seq<org.apache.calcite.sql.SqlFunction> |
UserDefinedFunctionUtils$.createTableSqlFunctions(String name,
TableFunction<?> tableFunction,
TypeInformation<?> resultType,
FlinkTypeFactory typeFactory)
Create
SqlFunction s for a TableFunction 's every eval method |
Constructor and Description |
---|
TableSqlFunction(String name,
TableFunction<?> udtf,
TypeInformation<?> rowTypeInfo,
org.apache.calcite.sql.type.SqlReturnTypeInference returnTypeInference,
org.apache.calcite.sql.type.SqlOperandTypeInference operandTypeInference,
org.apache.calcite.sql.type.SqlOperandTypeChecker operandTypeChecker,
List<org.apache.calcite.rel.type.RelDataType> paramTypes,
FlinkTableFunctionImpl<?> functionImpl) |
Constructor and Description |
---|
LogicalTableFunctionCall(String functionName,
TableFunction<?> tableFunction,
scala.collection.Seq<Expression> parameters,
TypeInformation<?> resultType,
String[] fieldNames,
LogicalNode child) |
Modifier and Type | Class and Description |
---|---|
class |
BooleanExplodeTableFunc |
class |
ByteExplodeTableFunc |
class |
DoubleExplodeTableFunc |
class |
FloatExplodeTableFunc |
class |
IntExplodeTableFunc |
class |
LongExplodeTableFunc |
class |
ObjectExplodeTableFunc |
class |
ShortExplodeTableFunc |
Modifier and Type | Method and Description |
---|---|
TableFunction<?> |
ExplodeFunctionUtil$.explodeTableFuncFromType(TypeInformation<?> ti) |
static TableFunction<?> |
ExplodeFunctionUtil.explodeTableFuncFromType(TypeInformation<?> ti) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.