org.apache.flink.table.planner.functions.aggfunctions

Class SumWithRetractAggFunction.DecimalSumWithRetractAggFunction

java.lang.Object

org.apache.flink.table.functions.UserDefinedFunction

org.apache.flink.table.functions.DeclarativeAggregateFunction

org.apache.flink.table.planner.functions.aggfunctions.SumWithRetractAggFunction

org.apache.flink.table.planner.functions.aggfunctions.SumWithRetractAggFunction.DecimalSumWithRetractAggFunction

All Implemented Interfaces:

Serializable, FunctionDefinition

Enclosing class:

SumWithRetractAggFunction

public static class SumWithRetractAggFunction.DecimalSumWithRetractAggFunction
extends SumWithRetractAggFunction

Built-in Decimal Sum with retract aggregate function.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.table.planner.functions.aggfunctions.SumWithRetractAggFunction

SumWithRetractAggFunction.ByteSumWithRetractAggFunction, SumWithRetractAggFunction.DecimalSumWithRetractAggFunction, SumWithRetractAggFunction.DoubleSumWithRetractAggFunction, SumWithRetractAggFunction.FloatSumWithRetractAggFunction, SumWithRetractAggFunction.IntSumWithRetractAggFunction, SumWithRetractAggFunction.LongSumWithRetractAggFunction, SumWithRetractAggFunction.ShortSumWithRetractAggFunction

Constructor Summary

Constructors

Constructor and Description
DecimalSumWithRetractAggFunction(DecimalType decimalType)

Method Summary

Modifier and Type	Method and Description
protected UnresolvedCallExpression	adjustedMinus(Expression arg1, UnresolvedReferenceExpression arg2)
protected UnresolvedCallExpression	adjustedPlus(UnresolvedReferenceExpression arg1, UnresolvedReferenceExpression arg2)
DataType	getResultType() The result type of the function.
protected Expression	zeroLiteral()

Methods inherited from class org.apache.flink.table.planner.functions.aggfunctions.SumWithRetractAggFunction

accumulateExpressions, aggBufferAttributes, getAggBufferTypes, getValueExpression, initialValuesExpressions, mergeExpressions, operandCount, retractExpressions

Methods inherited from class org.apache.flink.table.functions.DeclarativeAggregateFunction

getKind, getTypeInference, mergeOperand, mergeOperands, operand, operands

Methods inherited from class org.apache.flink.table.functions.UserDefinedFunction

close, functionIdentifier, open, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.flink.table.functions.FunctionDefinition

getRequirements, isDeterministic

Constructor Detail

DecimalSumWithRetractAggFunction

public DecimalSumWithRetractAggFunction(DecimalType decimalType)

Method Detail

getResultType

public DataType getResultType()

Description copied from class: DeclarativeAggregateFunction

The result type of the function.

Specified by:

getResultType in class DeclarativeAggregateFunction

zeroLiteral

protected Expression zeroLiteral()

Specified by:

zeroLiteral in class SumWithRetractAggFunction

adjustedPlus

protected UnresolvedCallExpression adjustedPlus(UnresolvedReferenceExpression arg1,
                                                UnresolvedReferenceExpression arg2)

Overrides:

adjustedPlus in class SumWithRetractAggFunction

adjustedMinus

protected UnresolvedCallExpression adjustedMinus(Expression arg1,
                                                 UnresolvedReferenceExpression arg2)

Overrides:

adjustedMinus in class SumWithRetractAggFunction