#include <coherence/util/aggregator/ParallelCompositeAggregator.hpp>
Inherits CompositeAggregator, and InvocableMap::ParallelAwareAggregator.
The size of the returned list will always be equal to the length of the aggregators' array.
Unlike many other concrete EntryAggregator implementations that are constructed directly, instances of ParallelCompositeAggregator should only becreated indirectly by using the factory method of CompositeAggregator.
Public Types | ||||
typedef spec::Handle | Handle | |||
ParallelCompositeAggregator Handle definition. | ||||
typedef spec::View | View | |||
ParallelCompositeAggregator View definition. | ||||
typedef spec::Holder | Holder | |||
ParallelCompositeAggregator Holder definition. | ||||
Public Member Functions | ||||
virtual InvocableMap::EntryAggregator::Handle | getParallelAggregator () | |||
Get an aggregator that can take the place of this aggregator in situations in which the InvocableMap can aggregate in parallel.
| ||||
virtual Object::Holder | aggregateResults (Collection::View vCollResults) | |||
Aggregate the results of the parallel aggregations.
| ||||
Protected Member Functions | ||||
ParallelCompositeAggregator () | ||||
Default constructor (necessary for the PortableObject interface). | ||||
ParallelCompositeAggregator (ObjectArray::View vaAggregator) | ||||
Construct a ParallelCompositeAggregator based on a specified coherence::util::InvocableMap::EntryAggregator array. |
ParallelCompositeAggregator | ( | ObjectArray::View | vaAggregator | ) | [protected] |
Construct a ParallelCompositeAggregator based on a specified coherence::util::InvocableMap::EntryAggregator array.
vaAggregator | an array of ParallelAwareAggregator objects; may not be null |