Uses of Interface
com.loomcache.server.compute.Aggregator

Packages that use Aggregator

Package	Description
com.loomcache.server.compute
com.loomcache.server.datastructures

Uses of Aggregator in com.loomcache.server.compute

Classes in com.loomcache.server.compute that implement Aggregator

Modifier and Type	Class	Description
class	AverageAggregator<K, V extends Number>	Built-in aggregator that computes the average of numeric values in the map.
class	BigDecimalAverageAggregator<K, V extends Number>	Built-in aggregator that averages numeric values exactly as BigDecimal.
class	BigDecimalSumAggregator<K, V extends Number>	Built-in aggregator that sums numeric values exactly as BigDecimal.
class	BigIntegerSumAggregator<K, V extends Number>	Built-in aggregator that sums integral numeric values exactly as BigInteger.
class	ComparableMaxAggregator<K, V extends Comparable<? super V>>	Built-in aggregator that returns the maximum value by natural ordering.
class	ComparableMinAggregator<K, V extends Comparable<? super V>>	Built-in aggregator that returns the minimum value by natural ordering.
class	CountAggregator<K,V>	Built-in aggregator that counts entries in the map.
class	DistinctValuesAggregator<K,V>	Built-in aggregator that collects distinct values from the map.
class	MaxAggregator<K, V extends Number>	Built-in aggregator that finds the maximum numeric value in the map.
class	MinAggregator<K, V extends Number>	Built-in aggregator that finds the minimum numeric value in the map.
class	SumAggregator<K, V extends Number>	Built-in aggregator that sums numeric values from the map.

Methods in com.loomcache.server.compute that return Aggregator

Modifier and Type	Method	Description
Aggregator<K,V,R>	Aggregator.combine(Aggregator<K,V,R> other)	Combine this aggregator with another from a parallel execution.
Aggregator<K,V,Double>	AverageAggregator.combine(Aggregator<K,V,Double> other)
Aggregator<K, V, BigDecimal>	BigDecimalAverageAggregator.combine(Aggregator<K, V, BigDecimal> other)
Aggregator<K, V, BigDecimal>	BigDecimalSumAggregator.combine(Aggregator<K, V, BigDecimal> other)
Aggregator<K, V, BigInteger>	BigIntegerSumAggregator.combine(Aggregator<K, V, BigInteger> other)
Aggregator<K,V,V>	ComparableMaxAggregator.combine(Aggregator<K,V,V> other)
Aggregator<K,V,V>	ComparableMinAggregator.combine(Aggregator<K,V,V> other)
Aggregator<K,V,Long>	CountAggregator.combine(Aggregator<K,V,Long> other)
Aggregator<K,V,Set<V>>	DistinctValuesAggregator.combine(Aggregator<K,V,Set<V>> other)
Aggregator<K,V,Double>	MaxAggregator.combine(Aggregator<K,V,Double> other)
Aggregator<K,V,Double>	MinAggregator.combine(Aggregator<K,V,Double> other)
Aggregator<K,V,Double>	SumAggregator.combine(Aggregator<K,V,Double> other)

Methods in com.loomcache.server.compute with parameters of type Aggregator

Modifier and Type	Method	Description
<R> R	EntryProcessorExecutor.aggregate(Aggregator<K,V,R> aggregator)	Scan all entries in the map and aggregate results using the provided aggregator.
Aggregator<K,V,R>	Aggregator.combine(Aggregator<K,V,R> other)	Combine this aggregator with another from a parallel execution.
Aggregator<K,V,Double>	AverageAggregator.combine(Aggregator<K,V,Double> other)
Aggregator<K, V, BigDecimal>	BigDecimalAverageAggregator.combine(Aggregator<K, V, BigDecimal> other)
Aggregator<K, V, BigDecimal>	BigDecimalSumAggregator.combine(Aggregator<K, V, BigDecimal> other)
Aggregator<K, V, BigInteger>	BigIntegerSumAggregator.combine(Aggregator<K, V, BigInteger> other)
Aggregator<K,V,V>	ComparableMaxAggregator.combine(Aggregator<K,V,V> other)
Aggregator<K,V,V>	ComparableMinAggregator.combine(Aggregator<K,V,V> other)
Aggregator<K,V,Long>	CountAggregator.combine(Aggregator<K,V,Long> other)
Aggregator<K,V,Set<V>>	DistinctValuesAggregator.combine(Aggregator<K,V,Set<V>> other)
Aggregator<K,V,Double>	MaxAggregator.combine(Aggregator<K,V,Double> other)
Aggregator<K,V,Double>	MinAggregator.combine(Aggregator<K,V,Double> other)
Aggregator<K,V,Double>	SumAggregator.combine(Aggregator<K,V,Double> other)

Method parameters in com.loomcache.server.compute with type arguments of type Aggregator

Modifier and Type	Method	Description
<R> R	EntryProcessorExecutor.aggregate(Supplier<? extends Aggregator<K,V,R>> aggregatorFactory)	Run a two-stage map-reduce aggregation over all visible entries.
<R> R	EntryProcessorExecutor.aggregate(Supplier<? extends Aggregator<K,V,R>> aggregatorFactory, MapPredicate<K,V> predicate)	Run a two-stage map-reduce aggregation over entries matching predicate.
<R> R	EntryProcessorExecutor.aggregate(Supplier<? extends Aggregator<K,V,R>> aggregatorFactory, MapPredicate<K,V> predicate, int partitionCount)	Run a two-stage map-reduce aggregation with an explicit maximum map-stage count.

Uses of Aggregator in com.loomcache.server.datastructures

Methods in com.loomcache.server.datastructures with parameters of type Aggregator

Modifier and Type	Method	Description
<R> R	DistributedMap.aggregate(Aggregator<K,V,R> aggregator)	Aggregate all visible entries using a single aggregator instance.

Method parameters in com.loomcache.server.datastructures with type arguments of type Aggregator

Modifier and Type	Method	Description
<R> R	DistributedMap.aggregate(Supplier<? extends Aggregator<K,V,R>> aggregatorFactory)	Aggregate all visible entries with two-stage map-reduce combine semantics.
<R> R	DistributedMap.aggregate(Supplier<? extends Aggregator<K,V,R>> aggregatorFactory, MapPredicate<K,V> predicate)	Aggregate visible entries matching predicate with two-stage map-reduce combine semantics.