Skip navigation links

com.tangosol.util
Interface InvocableMap.ParallelAwareAggregator

All Superinterfaces:

InvocableMap.EntryAggregator, java.io.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, QueryRecorder, ReducerAggregator, TopNAggregator

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.

Nested Class Summary

static interface

InvocableMap.ParallelAwareAggregator.PartialResultAggregator PartialResultAggregator allows for the intermediate aggregation of the partial results of a parallel aggregation.

Method Summary

java.lang.Object	aggregateResults(java.util.Collection collResults) Aggregate the partial results of the parallel aggregations into a final result.
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.

If the returned aggregator is a InvocableMap.ParallelAwareAggregator.PartialResultAggregator, the partial results of the parallel aggregation may be further aggregated where optimal.

Returns:

the aggregator that will be run in parallel

aggregateResults

java.lang.Object aggregateResults(java.util.Collection collResults)

Aggregate the partial results of the parallel aggregations into a final result.

Parameters:

collResults - the parallel aggregation results

Returns:

the aggregation of the parallel aggregation results

Skip navigation links