com.tangosol.util
Interface InvocableMap.ParallelAwareAggregator

All Superinterfaces:

InvocableMap.EntryAggregator, Serializable

All Known Implementing Classes:

AbstractAggregator, AbstractBigDecimalAggregator, AbstractComparableAggregator, AbstractDoubleAggregator, AbstractLongAggregator, BigDecimalAverage, BigDecimalMax, BigDecimalMin, BigDecimalSum, ComparableMax, ComparableMin, CompositeAggregator.Parallel, Count, DistinctValues, DoubleAverage, DoubleMax, DoubleMin, DoubleSum, GroupAggregator.Parallel, LongMax, LongMin, LongSum, PriorityAggregator

Enclosing interface:

InvocableMap

public static interface InvocableMap.ParallelAwareAggregator
extends InvocableMap.EntryAggregator

A ParallelAwareAggregator is an advanced extension to EntryAggregator that is explicitly capable of being run in parallel, for example in a distributed environment.

Method Summary

Object	aggregateResults(Collection collResults) Aggregate the results of the parallel aggregations.
InvocableMap.EntryAggregator	getParallelAggregator() Get an aggregator that can take the place of this aggregator in situations in which the InvocableMap can aggregate in parallel.

Methods inherited from interface com.tangosol.util.InvocableMap.EntryAggregator

aggregate

Method Detail

getParallelAggregator

InvocableMap.EntryAggregator getParallelAggregator()

Get an aggregator that can take the place of this aggregator in situations in which the InvocableMap can aggregate in parallel.

Returns:

the aggregator that will be run in parallel

aggregateResults

Object aggregateResults(Collection collResults)

Aggregate the results of the parallel aggregations.

Returns:

the aggregation of the parallel aggregation results