public abstract class SumAggFunction extends DeclarativeAggregateFunction
Modifier and Type | Class and Description |
---|---|
static class |
SumAggFunction.ByteSumAggFunction
Built-in Byte Sum aggregate function.
|
static class |
SumAggFunction.DecimalSumAggFunction
Built-in Decimal Sum aggregate function.
|
static class |
SumAggFunction.DoubleSumAggFunction
Built-in Double Sum aggregate function.
|
static class |
SumAggFunction.FloatSumAggFunction
Built-in Float Sum aggregate function.
|
static class |
SumAggFunction.IntSumAggFunction
Built-in Int Sum aggregate function.
|
static class |
SumAggFunction.LongSumAggFunction
Built-in Long Sum aggregate function.
|
static class |
SumAggFunction.ShortSumAggFunction
Built-in Short Sum aggregate function.
|
Constructor and Description |
---|
SumAggFunction() |
Modifier and Type | Method and Description |
---|---|
Expression[] |
accumulateExpressions()
Expressions for accumulating the mutable aggregation buffer based on an input row.
|
protected UnresolvedCallExpression |
adjustedPlus(UnresolvedReferenceExpression arg1,
UnresolvedReferenceExpression arg2) |
UnresolvedReferenceExpression[] |
aggBufferAttributes()
All fields of the aggregate buffer.
|
DataType[] |
getAggBufferTypes()
All types of the aggregate buffer.
|
Expression |
getValueExpression()
An expression which returns the final value for this aggregate function.
|
Expression[] |
initialValuesExpressions()
Expressions for initializing empty aggregation buffers.
|
Expression[] |
mergeExpressions()
A sequence of expressions for merging two aggregation buffers together.
|
int |
operandCount()
How many operands your function will deal with.
|
Expression[] |
retractExpressions()
Expressions for retracting the mutable aggregation buffer based on an input row.
|
getKind, getResultType, getTypeInference, mergeOperand, mergeOperands, operand, operands
close, functionIdentifier, open, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getRequirements, isDeterministic, supportsConstantFolding
public int operandCount()
DeclarativeAggregateFunction
operandCount
in class DeclarativeAggregateFunction
public UnresolvedReferenceExpression[] aggBufferAttributes()
DeclarativeAggregateFunction
aggBufferAttributes
in class DeclarativeAggregateFunction
public DataType[] getAggBufferTypes()
DeclarativeAggregateFunction
getAggBufferTypes
in class DeclarativeAggregateFunction
public Expression[] initialValuesExpressions()
DeclarativeAggregateFunction
initialValuesExpressions
in class DeclarativeAggregateFunction
public Expression[] accumulateExpressions()
DeclarativeAggregateFunction
accumulateExpressions
in class DeclarativeAggregateFunction
public Expression[] retractExpressions()
DeclarativeAggregateFunction
retractExpressions
in class DeclarativeAggregateFunction
public Expression[] mergeExpressions()
DeclarativeAggregateFunction
attributeName
and mergeOperand(attributeName)
to refer to the attributes corresponding to each of the buffers
being merged.mergeExpressions
in class DeclarativeAggregateFunction
protected UnresolvedCallExpression adjustedPlus(UnresolvedReferenceExpression arg1, UnresolvedReferenceExpression arg2)
public Expression getValueExpression()
DeclarativeAggregateFunction
getValueExpression
in class DeclarativeAggregateFunction
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.