Package | Description |
---|---|
org.apache.flink.table.functions.utils |
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 . |
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) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.