public class AggSqlFunction extends SqlUserDefinedAggFunction
param: name function name (used by SQL parser) param: aggregateFunction aggregate function to be called param: returnType the type information of returned value param: typeFactory type factory for converting Flink's between Calcite's types
function
Constructor and Description |
---|
AggSqlFunction(String name,
AggregateFunction<?,?> aggregateFunction,
TypeInformation<?> returnType,
FlinkTypeFactory typeFactory,
boolean requiresOver) |
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 AggSqlFunction |
apply(String name,
AggregateFunction<?,?> aggregateFunction,
TypeInformation<?> returnType,
FlinkTypeFactory typeFactory,
boolean requiresOver) |
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.sql.type.SqlOperandTypeChecker |
createOperandTypeChecker(AggregateFunction<?,?> aggregateFunction) |
static org.apache.calcite.sql.type.SqlOperandTypeInference |
createOperandTypeInference(AggregateFunction<?,?> aggregateFunction,
FlinkTypeFactory typeFactory) |
static org.apache.calcite.sql.type.SqlReturnTypeInference |
createReturnTypeInference(TypeInformation<?> resultType,
FlinkTypeFactory typeFactory) |
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) |
AggregateFunction<?,?> |
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<org.apache.calcite.rel.type.RelDataType> |
getParameterTypes(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory) |
static List<String> |
getParamNames() |
static List<org.apache.calcite.rel.type.RelDataType> |
getParamTypes() |
static org.apache.calcite.rel.type.RelDataType |
getReturnType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory) |
static org.apache.calcite.sql.type.SqlReturnTypeInference |
getReturnTypeInference() |
static int |
getRightPrec() |
static String |
getSignatureTemplate(int x$1) |
static org.apache.calcite.sql.SqlIdentifier |
getSqlIdentifier() |
static org.apache.calcite.sql.SqlSyntax |
getSyntax() |
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 <T> T |
unwrap(Class<T> x$1) |
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) |
getParameterTypes, getReturnType
isAggregator, isQuantifierAllowed, requiresOrder, requiresOver, unwrap, validateCall
deriveType, getFunctionType, getNameAsId, getParamNames, getParamTypes, getSqlIdentifier, getSyntax, unparse, 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, isDeterministic, isDynamicFunction, isGroup, isGroupAuxiliary, isName, leftPrec, preValidateCall, requiresDecimalExpansion, rewriteCall, rightPrec, toString, unparseListClause, unparseListClause, validateOperands, validRexOperands
public AggSqlFunction(String name, AggregateFunction<?,?> aggregateFunction, TypeInformation<?> returnType, FlinkTypeFactory typeFactory, boolean requiresOver)
public static AggSqlFunction apply(String name, AggregateFunction<?,?> aggregateFunction, TypeInformation<?> returnType, FlinkTypeFactory typeFactory, boolean requiresOver)
public static org.apache.calcite.sql.type.SqlOperandTypeInference createOperandTypeInference(AggregateFunction<?,?> aggregateFunction, FlinkTypeFactory typeFactory)
public static org.apache.calcite.sql.type.SqlReturnTypeInference createReturnTypeInference(TypeInformation<?> resultType, FlinkTypeFactory typeFactory)
public static org.apache.calcite.sql.type.SqlOperandTypeChecker createOperandTypeChecker(AggregateFunction<?,?> aggregateFunction)
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 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()
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 <T> T unwrap(Class<T> x$1)
public static boolean isAggregator()
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)
public static final boolean requiresOrder()
public static final boolean requiresOver()
public static List<org.apache.calcite.rel.type.RelDataType> getParameterTypes(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)
public static org.apache.calcite.rel.type.RelDataType getReturnType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)
public AggregateFunction<?,?> getFunction()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.