Package org.eclipse.collections.impl.block.procedure

Class MutatingAggregationProcedure<T,K,V>

java.lang.Object

org.eclipse.collections.impl.block.procedure.MutatingAggregationProcedure<T,K,V>

All Implemented Interfaces:

java.io.Serializable, java.util.function.Consumer<T>, Procedure<T>

public final class MutatingAggregationProcedure<T,K,V>
extends java.lang.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

Field Summary

Fields

Modifier and Type	Field	Description
private Function<? super T,? extends K>	groupBy
private MutableMapIterable<K,V>	map
private Procedure2<? super V,? super T>	mutatingAggregator
private static long	serialVersionUID
private Function0<? extends V>	zeroValueFactory

Constructor Summary

Constructors

Constructor	Description
MutatingAggregationProcedure(MutableMapIterable<K,V> map, Function<? super T,? extends K> groupBy, Function0<? extends V> zeroValueFactory, Procedure2<? super V,? super T> mutatingAggregator)

Method Summary

Modifier and Type	Method	Description
void	value(T each)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Consumer

andThen

Methods inherited from interface org.eclipse.collections.api.block.procedure.Procedure

accept

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

map

private final MutableMapIterable<K,V> map

groupBy

private final Function<? super T,? extends K> groupBy

zeroValueFactory

private final Function0<? extends V> zeroValueFactory

mutatingAggregator

private final Procedure2<? super V,? super T> mutatingAggregator

Constructor Detail

MutatingAggregationProcedure

public MutatingAggregationProcedure(MutableMapIterable<K,V> map,
                                    Function<? super T,? extends K> groupBy,
                                    Function0<? extends V> zeroValueFactory,
                                    Procedure2<? super V,? super T> mutatingAggregator)

Method Detail

value

public void value(T each)

Specified by:

value in interface Procedure<T>