Class PickAnyAccumulator<T>

java.lang.Object
com.hazelcast.jet.accumulator.PickAnyAccumulator<T>
Type Parameters:
T -

public class PickAnyAccumulator<T>
extends Object
Keeps the state needed to implement the AggregateOperations.pickAny() aggregate operation. It maintains the count of accumulated items so that it can properly set its value to null when all the items are deducted.
Since:
4.5