#include <coherence/util/aggregator/CompositeAggregator.hpp>
Inherits Object, PortableObject, and InvocableMap::EntryAggregator.
Inherited by ParallelCompositeAggregator.
The size of the returned list will always be equal to the length of the aggregators' array.
Public Types | ||||
typedef spec::Handle | Handle | |||
CompositeAggregator Handle definition. | ||||
typedef spec::View | View | |||
CompositeAggregator View definition. | ||||
typedef spec::Holder | Holder | |||
CompositeAggregator Holder definition. | ||||
Public Member Functions | ||||
virtual Object::Holder | aggregate (Set::View vSetEntries) | |||
Process a set of InvocableMap::Entry objects in order to produce an aggregated result.
| ||||
virtual void | readExternal (PofReader::Handle hIn) | |||
virtual void | writeExternal (PofWriter::Handle hOut) const | |||
virtual bool | equals (Object::View v) const | |||
virtual size32_t | hashCode () const | |||
Return a hash code value for the Object. This method is supported for the benefit of hash-based containers.
The general contract of
The default implementation is identity based.
| ||||
virtual void | toStream (std::ostream &out) const | |||
Output a human-readable description of this Object to the given stream. coherence::lang::operator<<(std::ostream, Object::View) is defined and will call into the toStream method, to output Objects. If a managed String object is desired, the COH_TO_STRING macro can be used to build up a String from streamable contents.
Object::View vKey = ... Object::View vValue = ... std::cout << vKey << " = " << vValue << std::endl; String::Handle hs = COH_TO_STRING(vKey << " = " << vValue);
| ||||
virtual ObjectArray::View | getAggregators () const | |||
Determine the ValueExtractor whose values this aggregator is aggregating. | ||||
Static Public Member Functions | ||||
static CompositeAggregator::Handle | create () | |||
Default constructor (necessary for the PortableObject interface). | ||||
static CompositeAggregator::Handle | create (ObjectArray::View vaAggregator) | |||
Create an instance of CompositeAggregator based on a specified array of coherence::util::InvocableMap::EntryAggregator. | ||||
Protected Attributes | ||||
FinalView< ObjectArray > | f_vaAggregator | |||
The underlying EntryAggregator array. |
static CompositeAggregator::Handle create | ( | ObjectArray::View | vaAggregator | ) | [static] |
Create an instance of CompositeAggregator based on a specified array of coherence::util::InvocableMap::EntryAggregator.
If all the aggregators in the specified array are instances of coherence::util::InvocableMap::ParallelAwareAggregator then a parallel-aware instance of the CompositeAggregator will be created.
If at least one of the specified aggregator is not parallel-aware, then the resulting CompositeAggregator will not be parallel-aware and could be ill-suited for aggregations run against large partitioned caches.
vaAggregator | an array of EntryAggregator objects; must contain not less than two aggregators |
virtual ObjectArray::View getAggregators | ( | ) | const [virtual] |
Determine the ValueExtractor whose values this aggregator is aggregating.