Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.calcite | |
org.apache.flink.table.functions.utils | |
org.apache.flink.table.plan.schema |
Modifier and Type | Method and Description |
---|---|
FlinkTypeFactory |
TableEnvironment.getTypeFactory()
Returns the
FlinkTypeFactory of this TableEnvironment. |
Modifier and Type | Method and Description |
---|---|
FlinkTypeFactory |
FlinkRelBuilder.getTypeFactory() |
Constructor and Description |
---|
FlinkPlannerImpl(org.apache.calcite.tools.FrameworkConfig config,
org.apache.calcite.plan.RelOptPlanner planner,
FlinkTypeFactory typeFactory) |
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 org.apache.calcite.sql.type.SqlOperandTypeInference |
ScalarSqlFunction.createOperandTypeInference(ScalarFunction scalarFunction,
FlinkTypeFactory typeFactory) |
org.apache.calcite.sql.type.SqlOperandTypeInference |
ScalarSqlFunction$.createOperandTypeInference(ScalarFunction scalarFunction,
FlinkTypeFactory typeFactory) |
static org.apache.calcite.sql.type.SqlReturnTypeInference |
ScalarSqlFunction.createReturnTypeInference(String name,
ScalarFunction scalarFunction,
FlinkTypeFactory typeFactory) |
org.apache.calcite.sql.type.SqlReturnTypeInference |
ScalarSqlFunction$.createReturnTypeInference(String name,
ScalarFunction scalarFunction,
FlinkTypeFactory typeFactory) |
static org.apache.calcite.sql.SqlFunction |
UserDefinedFunctionUtils.createScalarSqlFunction(String name,
ScalarFunction function,
FlinkTypeFactory typeFactory)
Create
SqlFunction for a ScalarFunction |
org.apache.calcite.sql.SqlFunction |
UserDefinedFunctionUtils$.createScalarSqlFunction(String name,
ScalarFunction function,
FlinkTypeFactory typeFactory)
Create
SqlFunction for a ScalarFunction |
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 |
---|
ScalarSqlFunction(String name,
ScalarFunction scalarFunction,
FlinkTypeFactory typeFactory) |
Constructor and Description |
---|
CompositeRelDataType(CompositeType<?> compositeType,
FlinkTypeFactory typeFactory) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.