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 <R> R |
acceptCall(org.apache.calcite.sql.util.SqlVisitor<R> x$1,
org.apache.calcite.sql.SqlCall x$2) |
static <R> void |
acceptCall(org.apache.calcite.sql.util.SqlVisitor<R> x$1,
org.apache.calcite.sql.SqlCall x$2,
boolean x$3,
org.apache.calcite.sql.util.SqlBasicVisitor.ArgHandler<R> x$4) |
protected static org.apache.calcite.rel.type.RelDataType |
adjustType(org.apache.calcite.sql.validate.SqlValidator x$1,
org.apache.calcite.sql.SqlCall x$2,
org.apache.calcite.rel.type.RelDataType x$3) |
static boolean |
allowsFraming() |
static TableSqlFunction |
apply(String name,
TableFunction<?> udtf,
TypeInformation<?> rowTypeInfo,
FlinkTypeFactory typeFactory,
FlinkTableFunctionImpl<?> functionImpl)
Util function to create a
TableSqlFunction . |
static boolean |
argumentMustBeScalar(int x$1) |
protected static void |
checkOperandCount(org.apache.calcite.sql.validate.SqlValidator x$1,
org.apache.calcite.sql.type.SqlOperandTypeChecker x$2,
org.apache.calcite.sql.SqlCall x$3) |
static boolean |
checkOperandTypes(org.apache.calcite.sql.SqlCallBinding x$1,
boolean x$2) |
protected static List<String> |
constructArgNameList(org.apache.calcite.sql.SqlCall x$1) |
protected static List<org.apache.calcite.rel.type.RelDataType> |
constructArgTypeList(org.apache.calcite.sql.validate.SqlValidator x$1,
org.apache.calcite.sql.validate.SqlValidatorScope x$2,
org.apache.calcite.sql.SqlCall x$3,
List<org.apache.calcite.sql.SqlNode> x$4,
boolean x$5) |
protected static List<org.apache.calcite.sql.SqlNode> |
constructOperandList(org.apache.calcite.sql.validate.SqlValidator x$1,
org.apache.calcite.sql.SqlCall x$2,
List<String> x$3) |
static org.apache.calcite.sql.SqlCall |
createCall(org.apache.calcite.sql.SqlLiteral x$1,
org.apache.calcite.sql.parser.SqlParserPos x$2,
org.apache.calcite.sql.SqlNode[] x$3) |
static org.apache.calcite.sql.SqlCall |
createCall(org.apache.calcite.sql.SqlNodeList x$1) |
static org.apache.calcite.sql.SqlCall |
createCall(org.apache.calcite.sql.parser.SqlParserPos x$1,
List<? extends org.apache.calcite.sql.SqlNode> x$2) |
static org.apache.calcite.sql.SqlCall |
createCall(org.apache.calcite.sql.parser.SqlParserPos x$1,
org.apache.calcite.sql.SqlNode[] x$2) |
static org.apache.calcite.rel.type.RelDataType |
deriveType(org.apache.calcite.sql.validate.SqlValidator x$1,
org.apache.calcite.sql.validate.SqlValidatorScope x$2,
org.apache.calcite.sql.SqlCall x$3) |
static boolean |
equals(Object x$1) |
static String |
getAllowedSignatures() |
static String |
getAllowedSignatures(String x$1) |
static Type |
getElementType(org.apache.calcite.rel.type.RelDataTypeFactory x$1,
List<org.apache.calcite.sql.SqlNode> x$2) |
static org.apache.calcite.schema.TableFunction |
getFunction() |
static org.apache.calcite.sql.SqlFunctionCategory |
getFunctionType() |
static org.apache.calcite.sql.SqlKind |
getKind() |
static int |
getLeftPrec() |
static org.apache.calcite.sql.validate.SqlMonotonicity |
getMonotonicity(org.apache.calcite.sql.SqlCall x$1,
org.apache.calcite.sql.validate.SqlValidatorScope x$2) |
static org.apache.calcite.sql.validate.SqlMonotonicity |
getMonotonicity(org.apache.calcite.sql.SqlOperatorBinding x$1) |
static String |
getName() |
static org.apache.calcite.sql.SqlIdentifier |
getNameAsId() |
static org.apache.calcite.sql.SqlOperandCountRange |
getOperandCountRange() |
static org.apache.calcite.sql.type.SqlOperandTypeChecker |
getOperandTypeChecker() |
static org.apache.calcite.sql.type.SqlOperandTypeInference |
getOperandTypeInference() |
static List<String> |
getParamNames() |
static List<org.apache.calcite.rel.type.RelDataType> |
getParamTypes() |
int[] |
getPojoFieldMapping()
Get additional mapping information if the returned table type is a POJO
(POJO types have no deterministic field order).
|
static org.apache.calcite.sql.type.SqlReturnTypeInference |
getReturnTypeInference() |
static int |
getRightPrec() |
static org.apache.calcite.rel.type.RelDataType |
getRowType(org.apache.calcite.rel.type.RelDataTypeFactory x$1,
List<org.apache.calcite.sql.SqlNode> x$2) |
TypeInformation<?> |
getRowTypeInfo()
Get the type information of the table returned by the table function.
|
static String |
getSignatureTemplate(int x$1) |
static org.apache.calcite.sql.SqlIdentifier |
getSqlIdentifier() |
static org.apache.calcite.sql.SqlSyntax |
getSyntax() |
TableFunction<?> |
getTableFunction()
Get the user-defined table function.
|
static int |
hashCode() |
static org.apache.calcite.rel.type.RelDataType |
inferReturnType(org.apache.calcite.rel.type.RelDataTypeFactory x$1,
List<org.apache.calcite.rel.type.RelDataType> x$2) |
static org.apache.calcite.rel.type.RelDataType |
inferReturnType(org.apache.calcite.sql.SqlOperatorBinding x$1) |
static boolean |
isAggregator() |
static boolean |
isDeterministic() |
static boolean |
isDynamicFunction() |
static boolean |
isGroup() |
static boolean |
isGroupAuxiliary() |
static boolean |
isName(String x$1) |
static boolean |
isQuantifierAllowed() |
static boolean |
needsSpace() |
protected static void |
preValidateCall(org.apache.calcite.sql.validate.SqlValidator x$1,
org.apache.calcite.sql.validate.SqlValidatorScope x$2,
org.apache.calcite.sql.SqlCall x$3) |
static boolean |
requiresDecimalExpansion() |
static boolean |
requiresOrder() |
static boolean |
requiresOver() |
static org.apache.calcite.sql.SqlNode |
rewriteCall(org.apache.calcite.sql.validate.SqlValidator x$1,
org.apache.calcite.sql.SqlCall x$2) |
static String |
toString() |
static void |
unparse(org.apache.calcite.sql.SqlWriter x$1,
org.apache.calcite.sql.SqlCall x$2,
int x$3,
int x$4) |
protected static void |
unparseListClause(org.apache.calcite.sql.SqlWriter x$1,
org.apache.calcite.sql.SqlNode x$2) |
protected static void |
unparseListClause(org.apache.calcite.sql.SqlWriter x$1,
org.apache.calcite.sql.SqlNode x$2,
org.apache.calcite.sql.SqlKind x$3) |
static void |
validateCall(org.apache.calcite.sql.SqlCall x$1,
org.apache.calcite.sql.validate.SqlValidator x$2,
org.apache.calcite.sql.validate.SqlValidatorScope x$3,
org.apache.calcite.sql.validate.SqlValidatorScope x$4) |
static org.apache.calcite.rel.type.RelDataType |
validateOperands(org.apache.calcite.sql.validate.SqlValidator x$1,
org.apache.calcite.sql.validate.SqlValidatorScope x$2,
org.apache.calcite.sql.SqlCall x$3) |
protected static void |
validateQuantifier(org.apache.calcite.sql.validate.SqlValidator x$1,
org.apache.calcite.sql.SqlCall x$2) |
static boolean |
validRexOperands(int x$1,
org.apache.calcite.util.Litmus x$2) |
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, isGroup, isGroupAuxiliary, 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 static org.apache.calcite.sql.type.SqlOperandTypeChecker getOperandTypeChecker()
public static org.apache.calcite.sql.SqlOperandCountRange getOperandCountRange()
public static String getName()
public static org.apache.calcite.sql.SqlKind getKind()
public static String toString()
public static int getLeftPrec()
public static int getRightPrec()
public static org.apache.calcite.sql.SqlCall createCall(org.apache.calcite.sql.SqlLiteral x$1, org.apache.calcite.sql.parser.SqlParserPos x$2, org.apache.calcite.sql.SqlNode[] x$3)
public static final org.apache.calcite.sql.SqlCall createCall(org.apache.calcite.sql.parser.SqlParserPos x$1, org.apache.calcite.sql.SqlNode[] x$2)
public static final org.apache.calcite.sql.SqlCall createCall(org.apache.calcite.sql.SqlNodeList x$1)
public static final org.apache.calcite.sql.SqlCall createCall(org.apache.calcite.sql.parser.SqlParserPos x$1, List<? extends org.apache.calcite.sql.SqlNode> x$2)
public static org.apache.calcite.sql.SqlNode rewriteCall(org.apache.calcite.sql.validate.SqlValidator x$1, org.apache.calcite.sql.SqlCall x$2)
protected static void unparseListClause(org.apache.calcite.sql.SqlWriter x$1, org.apache.calcite.sql.SqlNode x$2)
protected static void unparseListClause(org.apache.calcite.sql.SqlWriter x$1, org.apache.calcite.sql.SqlNode x$2, org.apache.calcite.sql.SqlKind x$3)
public static boolean equals(Object x$1)
public static boolean isName(String x$1)
public static int hashCode()
public static final org.apache.calcite.rel.type.RelDataType validateOperands(org.apache.calcite.sql.validate.SqlValidator x$1, org.apache.calcite.sql.validate.SqlValidatorScope x$2, org.apache.calcite.sql.SqlCall x$3)
protected static void preValidateCall(org.apache.calcite.sql.validate.SqlValidator x$1, org.apache.calcite.sql.validate.SqlValidatorScope x$2, org.apache.calcite.sql.SqlCall x$3)
public static org.apache.calcite.rel.type.RelDataType inferReturnType(org.apache.calcite.sql.SqlOperatorBinding x$1)
protected static List<String> constructArgNameList(org.apache.calcite.sql.SqlCall x$1)
protected static List<org.apache.calcite.sql.SqlNode> constructOperandList(org.apache.calcite.sql.validate.SqlValidator x$1, org.apache.calcite.sql.SqlCall x$2, List<String> x$3)
protected static List<org.apache.calcite.rel.type.RelDataType> constructArgTypeList(org.apache.calcite.sql.validate.SqlValidator x$1, org.apache.calcite.sql.validate.SqlValidatorScope x$2, org.apache.calcite.sql.SqlCall x$3, List<org.apache.calcite.sql.SqlNode> x$4, boolean x$5)
public static boolean needsSpace()
protected static org.apache.calcite.rel.type.RelDataType adjustType(org.apache.calcite.sql.validate.SqlValidator x$1, org.apache.calcite.sql.SqlCall x$2, org.apache.calcite.rel.type.RelDataType x$3)
public static final org.apache.calcite.rel.type.RelDataType inferReturnType(org.apache.calcite.rel.type.RelDataTypeFactory x$1, List<org.apache.calcite.rel.type.RelDataType> x$2)
public static boolean checkOperandTypes(org.apache.calcite.sql.SqlCallBinding x$1, boolean x$2)
protected static void checkOperandCount(org.apache.calcite.sql.validate.SqlValidator x$1, org.apache.calcite.sql.type.SqlOperandTypeChecker x$2, org.apache.calcite.sql.SqlCall x$3)
public static boolean validRexOperands(int x$1, org.apache.calcite.util.Litmus x$2)
public static String getSignatureTemplate(int x$1)
public static final String getAllowedSignatures()
public static org.apache.calcite.sql.type.SqlOperandTypeInference getOperandTypeInference()
public static boolean isAggregator()
public static boolean requiresOver()
public static boolean requiresOrder()
public static boolean allowsFraming()
public static boolean isGroup()
public static boolean isGroupAuxiliary()
public static <R> R acceptCall(org.apache.calcite.sql.util.SqlVisitor<R> x$1, org.apache.calcite.sql.SqlCall x$2)
public static <R> void acceptCall(org.apache.calcite.sql.util.SqlVisitor<R> x$1, org.apache.calcite.sql.SqlCall x$2, boolean x$3, org.apache.calcite.sql.util.SqlBasicVisitor.ArgHandler<R> x$4)
public static org.apache.calcite.sql.type.SqlReturnTypeInference getReturnTypeInference()
public static org.apache.calcite.sql.validate.SqlMonotonicity getMonotonicity(org.apache.calcite.sql.SqlCall x$1, org.apache.calcite.sql.validate.SqlValidatorScope x$2)
public static org.apache.calcite.sql.validate.SqlMonotonicity getMonotonicity(org.apache.calcite.sql.SqlOperatorBinding x$1)
public static boolean isDeterministic()
public static boolean isDynamicFunction()
public static boolean requiresDecimalExpansion()
public static boolean argumentMustBeScalar(int x$1)
public static org.apache.calcite.sql.SqlSyntax getSyntax()
public static org.apache.calcite.sql.SqlIdentifier getSqlIdentifier()
public static org.apache.calcite.sql.SqlIdentifier getNameAsId()
public static List<org.apache.calcite.rel.type.RelDataType> getParamTypes()
public static void unparse(org.apache.calcite.sql.SqlWriter x$1, org.apache.calcite.sql.SqlCall x$2, int x$3, int x$4)
public static org.apache.calcite.sql.SqlFunctionCategory getFunctionType()
public static boolean isQuantifierAllowed()
public static void validateCall(org.apache.calcite.sql.SqlCall x$1, org.apache.calcite.sql.validate.SqlValidator x$2, org.apache.calcite.sql.validate.SqlValidatorScope x$3, org.apache.calcite.sql.validate.SqlValidatorScope x$4)
protected static void validateQuantifier(org.apache.calcite.sql.validate.SqlValidator x$1, org.apache.calcite.sql.SqlCall x$2)
public static org.apache.calcite.rel.type.RelDataType deriveType(org.apache.calcite.sql.validate.SqlValidator x$1, org.apache.calcite.sql.validate.SqlValidatorScope x$2, org.apache.calcite.sql.SqlCall x$3)
public static org.apache.calcite.schema.TableFunction getFunction()
public static org.apache.calcite.rel.type.RelDataType getRowType(org.apache.calcite.rel.type.RelDataTypeFactory x$1, List<org.apache.calcite.sql.SqlNode> x$2)
public static Type getElementType(org.apache.calcite.rel.type.RelDataTypeFactory x$1, List<org.apache.calcite.sql.SqlNode> x$2)
public TableFunction<?> getTableFunction()
public TypeInformation<?> getRowTypeInfo()
public int[] getPojoFieldMapping()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.