Package com.tangosol.util

Interface InvocableMap.EntryAggregator<K,V,R>

Type Parameters:
K - the type of the Map entry keys
V - the type of the Map entry values
R - the type of the value returned by the EntryAggregator
All Superinterfaces:
Serializable
All Known Subinterfaces:
InvocableMap.ParallelAwareAggregator<K,V,P,R>, InvocableMap.StreamingAggregator<K,V,P,R>
All Known Implementing Classes:
AbstractAggregator, AbstractAsynchronousAggregator, AbstractBigDecimalAggregator, AbstractComparableAggregator, AbstractDoubleAggregator, AbstractLongAggregator, AsynchronousAggregator, BigDecimalAverage, BigDecimalMax, BigDecimalMin, BigDecimalSum, ComparableMax, ComparableMin, CompositeAggregator, CompositeAggregator.Parallel, Count, DistinctValues, DoubleAverage, DoubleMax, DoubleMin, DoubleSum, GroupAggregator, GroupAggregator.Parallel, LongMax, LongMin, LongSum, PartitionedJCacheStatistics.PartitionedCacheStatisticsAggregator, PartitionedJCacheStatistics.PartitionedCacheStatisticsClear, PriorityAggregator, QueryRecorder, ReducerAggregator, ScriptAggregator, SimilaritySearch, TopNAggregator
Enclosing interface:
InvocableMap<K,V>
public static interface InvocableMap.EntryAggregator<K,V,R> extends Serializable
An EntryAggregator represents processing that can be directed to occur against some subset of the entries in an InvocableMap, resulting in a aggregated result. Common examples of aggregation include functions such as min(), max() and avg(). However, the concept of aggregation applies to any process that needs to evaluate a group of entries to come up with a single answer.

  • Method Summary

    Modifier and Type
    Method
    Description
    R
    aggregate(Set<? extends InvocableMap.Entry<? extends K,? extends V>> setEntries)
    Process a set of InvocableMap.Entry objects in order to produce an aggregated result.

  • Method Details

    • aggregate

      R aggregate(Set<? extends InvocableMap.Entry<? extends K,? extends V>> setEntries)
      Process a set of InvocableMap.Entry objects in order to produce an aggregated result.
      Parameters:
      setEntries - a Set of read-only InvocableMap.Entry objects to aggregate
      Returns:
      the aggregated result from processing the entries