public static class SumAggFunction.DecimalSumAggFunction extends SumAggFunction
SumAggFunction.ByteSumAggFunction, SumAggFunction.DecimalSumAggFunction, SumAggFunction.DoubleSumAggFunction, SumAggFunction.FloatSumAggFunction, SumAggFunction.IntSumAggFunction, SumAggFunction.LongSumAggFunction, SumAggFunction.ShortSumAggFunction| 构造器和说明 |
|---|
DecimalSumAggFunction(org.apache.flink.table.types.logical.DecimalType decimalType) |
| 限定符和类型 | 方法和说明 |
|---|---|
protected org.apache.flink.table.expressions.UnresolvedCallExpression |
adjustedPlus(org.apache.flink.table.expressions.UnresolvedReferenceExpression arg1,
org.apache.flink.table.expressions.UnresolvedReferenceExpression arg2) |
org.apache.flink.table.types.DataType |
getResultType()
The result type of the function.
|
accumulateExpressions, aggBufferAttributes, getAggBufferTypes, getValueExpression, initialValuesExpressions, mergeExpressions, operandCount, retractExpressionsgetKind, getTypeInference, mergeOperand, mergeOperands, operand, operandsclose, functionIdentifier, open, toStringpublic DecimalSumAggFunction(org.apache.flink.table.types.logical.DecimalType decimalType)
public org.apache.flink.table.types.DataType getResultType()
DeclarativeAggregateFunctionprotected org.apache.flink.table.expressions.UnresolvedCallExpression adjustedPlus(org.apache.flink.table.expressions.UnresolvedReferenceExpression arg1,
org.apache.flink.table.expressions.UnresolvedReferenceExpression arg2)
adjustedPlus 在类中 SumAggFunctionCopyright © 2014–2022 The Apache Software Foundation. All rights reserved.