Interface AggregateFunction.Aggregate
-
- Enclosing interface:
- AggregateFunction
public static interface AggregateFunction.Aggregate
An aggregation operation.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
addInput(ProtocolVersion protocolVersion, java.util.List<java.nio.ByteBuffer> values)
Adds the specified input to this aggregate.java.nio.ByteBuffer
compute(ProtocolVersion protocolVersion)
Computes and returns the aggregate current value.void
reset()
Reset this aggregate.
-
-
-
Method Detail
-
addInput
void addInput(ProtocolVersion protocolVersion, java.util.List<java.nio.ByteBuffer> values) throws InvalidRequestException
Adds the specified input to this aggregate.- Parameters:
protocolVersion
- native protocol versionvalues
- the values to add to the aggregate.- Throws:
InvalidRequestException
-
compute
java.nio.ByteBuffer compute(ProtocolVersion protocolVersion) throws InvalidRequestException
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.
-
-