public abstract class Sum0AggFunction extends DeclarativeAggregateFunction
Modifier and Type | Class and Description |
---|---|
static class |
Sum0AggFunction.ByteSum0AggFunction
Built-in Byte Sum0 aggregate function.
|
static class |
Sum0AggFunction.DecimalSum0AggFunction
Built-in Decimal Sum0 aggregate function.
|
static class |
Sum0AggFunction.DoubleSum0AggFunction
Built-in Double Sum0 aggregate function.
|
static class |
Sum0AggFunction.FloatSum0AggFunction
Built-in Float Sum0 aggregate function.
|
static class |
Sum0AggFunction.IntSum0AggFunction
Built-in Int Sum0 aggregate function.
|
static class |
Sum0AggFunction.LongSum0AggFunction
Built-in Long Sum0 aggregate function.
|
static class |
Sum0AggFunction.ShortSum0AggFunction
Built-in Short Sum0 aggregate function.
|
Constructor and Description |
---|
Sum0AggFunction() |
Modifier and Type | Method and Description |
---|---|
Expression[] |
accumulateExpressions()
Expressions for accumulating the mutable aggregation buffer based on an input row.
|
protected UnresolvedCallExpression |
adjustedMinus(UnresolvedReferenceExpression arg1,
UnresolvedReferenceExpression arg2) |
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[] |
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, initialValuesExpressions, mergeOperand, mergeOperands, operand, operands
close, functionIdentifier, open, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getRequirements, isDeterministic
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[] 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
public Expression getValueExpression()
DeclarativeAggregateFunction
getValueExpression
in class DeclarativeAggregateFunction
protected UnresolvedCallExpression adjustedPlus(UnresolvedReferenceExpression arg1, UnresolvedReferenceExpression arg2)
protected UnresolvedCallExpression adjustedMinus(UnresolvedReferenceExpression arg1, UnresolvedReferenceExpression arg2)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.