Package com.hazelcast.jet.accumulator
Class PickAnyAccumulator<T>
java.lang.Object
com.hazelcast.jet.accumulator.PickAnyAccumulator<T>
- Type Parameters:
T
-
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:
- Jet 4.5
-
Constructor Summary
ConstructorDescriptionConstructs an emptypickAny
accumulator.PickAnyAccumulator
(T value) Constructs apickAny
accumulator with the full state passed in the parameters. -
Method Summary
-
Constructor Details
-
PickAnyAccumulator
public PickAnyAccumulator()Constructs an emptypickAny
accumulator. -
PickAnyAccumulator
Constructs apickAny
accumulator with the full state passed in the parameters.- Parameters:
value
- the picked object
-
-
Method Details