Skip navigation links
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, java.io.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, rotateLeft, rotateLeft, rotateLeft, rotateRight, rotateRight, rotateRight, 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 null
aggregator
- 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 java.lang.Object aggregateResults(java.util.Collection collResults)
- Aggregate the results of the parallel aggregations.
-
- Specified by:
aggregateResults
in interface InvocableMap.ParallelAwareAggregator
-
- Parameters:
collResults
- the parallel aggregation results
- Returns:
- the aggregation of the parallel aggregation results
Skip navigation links
Copyright © 2000, 2011, Oracle and/or its affiliates. All rights reserved.