com.tangosol.util.aggregator
Class GroupAggregator.Parallel
java.lang.Object
com.tangosol.util.Base
com.tangosol.util.BitHelper
com.tangosol.util.ExternalizableHelper
com.tangosol.util.aggregator.GroupAggregator
com.tangosol.util.aggregator.GroupAggregator.Parallel
- All Implemented Interfaces:
- ExternalizableLite, PortableObject, InvocableMap.EntryAggregator, InvocableMap.ParallelAwareAggregator, Serializable
- Enclosing class:
- GroupAggregator
public static class GroupAggregator.Parallel
- extends GroupAggregator
- implements InvocableMap.ParallelAwareAggregator
Parallel implementation of the GroupAggregator.
Methods inherited from class com.tangosol.util.aggregator.GroupAggregator |
aggregate, createInstance, createInstance, createInstance, createInstance, equals, getAggregator, getExtractor, hashCode, readExternal, readExternal, toString, writeExternal, writeExternal |
Methods inherited from class com.tangosol.util.BitHelper |
countBits, countBits, countBits, indexOfLSB, indexOfLSB, indexOfLSB, indexOfMSB, indexOfMSB, indexOfMSB, toBitString, toBitString, toBitString |
GroupAggregator.Parallel
public GroupAggregator.Parallel()
- Default constructor (necessary for the ExternalizableLite
interface).
GroupAggregator.Parallel
protected GroupAggregator.Parallel(ValueExtractor extractor,
InvocableMap.ParallelAwareAggregator aggregator,
Filter filter)
- Construct a Parallel aggregator based on a specified ValueExtractor
and underlying ParallelAwareAggregator.
- Parameters:
extractor
- a ValueExtractor object; may not be nullaggregator
- an EntryAggregator object; may not be null
getParallelAggregator
public InvocableMap.EntryAggregator getParallelAggregator()
- Get an aggregator that can take the place of this aggregator in
situations in which the InvocableMap can aggregate in parallel.
- Specified by:
getParallelAggregator
in interface InvocableMap.ParallelAwareAggregator
- Returns:
- the aggregator that will be run in parallel
aggregateResults
public Object aggregateResults(Collection collResults)
- Aggregate the results of the parallel aggregations.
- Specified by:
aggregateResults
in interface InvocableMap.ParallelAwareAggregator
- Returns:
- the aggregation of the parallel aggregation results