Uses of Interface
com.loomcache.server.compute.Aggregator
Packages that use Aggregator
-
Uses of Aggregator in com.loomcache.server.compute
Classes in com.loomcache.server.compute that implement AggregatorModifier and TypeClassDescriptionclassAverageAggregator<K, V extends Number>Built-in aggregator that computes the average of numeric values in the map.classBigDecimalAverageAggregator<K, V extends Number>Built-in aggregator that averages numeric values exactly asBigDecimal.classBigDecimalSumAggregator<K, V extends Number>Built-in aggregator that sums numeric values exactly asBigDecimal.classBigIntegerSumAggregator<K, V extends Number>Built-in aggregator that sums integral numeric values exactly asBigInteger.classComparableMaxAggregator<K, V extends Comparable<? super V>>Built-in aggregator that returns the maximum value by natural ordering.classComparableMinAggregator<K, V extends Comparable<? super V>>Built-in aggregator that returns the minimum value by natural ordering.classCountAggregator<K,V> Built-in aggregator that counts entries in the map.classBuilt-in aggregator that collects distinct values from the map.classMaxAggregator<K, V extends Number>Built-in aggregator that finds the maximum numeric value in the map.classMinAggregator<K, V extends Number>Built-in aggregator that finds the minimum numeric value in the map.classSumAggregator<K, V extends Number>Built-in aggregator that sums numeric values from the map.Methods in com.loomcache.server.compute that return AggregatorModifier and TypeMethodDescriptionAggregator<K, V, R> Aggregator.combine(Aggregator<K, V, R> other) Combine this aggregator with another from a parallel execution.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>> MaxAggregator.combine(Aggregator<K, V, Double> other) MinAggregator.combine(Aggregator<K, V, Double> other) SumAggregator.combine(Aggregator<K, V, Double> other) Methods in com.loomcache.server.compute with parameters of type AggregatorModifier and TypeMethodDescription<R> REntryProcessorExecutor.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.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>> MaxAggregator.combine(Aggregator<K, V, Double> other) MinAggregator.combine(Aggregator<K, V, Double> other) SumAggregator.combine(Aggregator<K, V, Double> other) Method parameters in com.loomcache.server.compute with type arguments of type AggregatorModifier and TypeMethodDescription<R> REntryProcessorExecutor.aggregate(Supplier<? extends Aggregator<K, V, R>> aggregatorFactory) Run a two-stage map-reduce aggregation over all visible entries.<R> REntryProcessorExecutor.aggregate(Supplier<? extends Aggregator<K, V, R>> aggregatorFactory, MapPredicate<K, V> predicate) Run a two-stage map-reduce aggregation over entries matchingpredicate.<R> REntryProcessorExecutor.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 AggregatorModifier and TypeMethodDescription<R> RDistributedMap.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 AggregatorModifier and TypeMethodDescription<R> RDistributedMap.aggregate(Supplier<? extends Aggregator<K, V, R>> aggregatorFactory) Aggregate all visible entries with two-stage map-reduce combine semantics.<R> RDistributedMap.aggregate(Supplier<? extends Aggregator<K, V, R>> aggregatorFactory, MapPredicate<K, V> predicate) Aggregate visible entries matchingpredicatewith two-stage map-reduce combine semantics.