Class MutatingAggregationProcedure<T,​K,​V>

All Implemented Interfaces:
Serializable, Consumer<T>, Procedure<T>

public final class MutatingAggregationProcedure<T,​K,​V>
extends Object
implements Procedure<T>
This procedure is used to apply an aggregate function like sum on a grouped set of data. The values in the grouping must be mutable using this procedure. An example would be using an AtomicInteger which can be mutated vs. an Integer which cannot.
See Also:
Serialized Form