public class TableSqlFunction
extends org.apache.calcite.sql.validate.SqlUserDefinedTableFunction
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) |
Modifier and Type | Method and Description |
---|---|
static TableSqlFunction |
apply(String name,
TableFunction<?> udtf,
TypeInformation<?> rowTypeInfo,
FlinkTypeFactory typeFactory,
FlinkTableFunctionImpl<?> functionImpl)
Util function to create a
TableSqlFunction . |
int[] |
getPojoFieldMapping()
Get additional mapping information if the returned table type is a POJO
(POJO types have no deterministic field order).
|
TypeInformation<?> |
getRowTypeInfo()
Get the type information of the table returned by the table function.
|
TableFunction<?> |
getTableFunction()
Get the user-defined table function.
|
getElementType, getFunction, getRowType
deriveType, getFunctionType, getNameAsId, getParamTypes, getSqlIdentifier, getSyntax, isQuantifierAllowed, unparse, validateCall, validateQuantifier
acceptCall, acceptCall, adjustType, allowsFraming, argumentMustBeScalar, checkOperandCount, checkOperandTypes, constructArgNameList, constructArgTypeList, constructOperandList, createCall, createCall, createCall, createCall, equals, getAllowedSignatures, getAllowedSignatures, getKind, getLeftPrec, getMonotonicity, getMonotonicity, getName, getOperandCountRange, getOperandTypeChecker, getOperandTypeInference, getReturnTypeInference, getRightPrec, getSignatureTemplate, hashCode, inferReturnType, inferReturnType, isAggregator, isDeterministic, isDynamicFunction, isName, leftPrec, preValidateCall, requiresDecimalExpansion, requiresOrder, requiresOver, rewriteCall, rightPrec, toString, unparseListClause, unparseListClause, validateOperands, validRexOperands
public 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)
public static TableSqlFunction apply(String name, TableFunction<?> udtf, TypeInformation<?> rowTypeInfo, FlinkTypeFactory typeFactory, FlinkTableFunctionImpl<?> functionImpl)
TableSqlFunction
.
name
- function name (used by SQL parser)udtf
- user-defined table function to be calledrowTypeInfo
- the row type information generated by the table functiontypeFactory
- type factory for converting Flink's between Calcite's typesfunctionImpl
- Calcite table function schemaTableSqlFunction
public TableFunction<?> getTableFunction()
public TypeInformation<?> getRowTypeInfo()
public int[] getPojoFieldMapping()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.