Interface AggregateFunction.Aggregate
- Enclosing interface:
- AggregateFunction
public static interface AggregateFunction.Aggregate
An aggregation operation.
-
Method Summary
Modifier and TypeMethodDescriptionvoidAdds the specified input to this aggregate.compute(ProtocolVersion protocolVersion) Computes and returns the aggregate current value.voidreset()Reset this aggregate.
-
Method Details
-
addInput
Adds the specified input to this aggregate.- Parameters:
arguments- the values to add to the aggregate.- Throws:
InvalidRequestException
-
compute
Computes and returns the aggregate current value.- Parameters:
protocolVersion- native protocol version- Returns:
- the aggregate current value.
- Throws:
InvalidRequestException
-
reset
void reset()Reset this aggregate.
-