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, 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 and 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 Detail

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