00001 /* 00002 * ParallelCompositeAggregator.hpp 00003 * 00004 * Copyright (c) 2000, 2013, Oracle and/or its affiliates. All rights reserved. 00005 * 00006 * Oracle is a registered trademarks of Oracle Corporation and/or its 00007 * affiliates. 00008 * 00009 * This software is the confidential and proprietary information of Oracle 00010 * Corporation. You shall not disclose such confidential and proprietary 00011 * information and shall use it only in accordance with the terms of the 00012 * license agreement you entered into with Oracle. 00013 * 00014 * This notice may not be removed or altered. 00015 */ 00016 #ifndef COH_PARALLEL_COMPOSITE_AGGREGATOR_HPP 00017 #define COH_PARALLEL_COMPOSITE_AGGREGATOR_HPP 00018 00019 #include "coherence/lang.ns" 00020 00021 #include "coherence/util/aggregator/CompositeAggregator.hpp" 00022 #include "coherence/util/InvocableMap.hpp" 00023 00024 COH_OPEN_NAMESPACE3(coherence,util,aggregator) 00025 00026 00027 /** 00028 * ParallelCompositeAggregator provides an ability to execute a collection of 00029 * parallel aware aggregators against the same subset of the entries in an 00030 * InvocableMap, resulting in a list of corresponding aggregation results. The 00031 * size of the returned list will always be equal to the length of the 00032 * aggregators' array. 00033 * 00034 * Unlike many other concrete EntryAggregator implementations that are 00035 * constructed directly, instances of ParallelCompositeAggregator should only 00036 * becreated indirectly by using the factory method of CompositeAggregator. 00037 * 00038 * @author djl 2008.05.16 00039 */ 00040 class COH_EXPORT ParallelCompositeAggregator 00041 : public class_spec<ParallelCompositeAggregator, 00042 extends<CompositeAggregator>, 00043 implements<InvocableMap::ParallelAwareAggregator> > 00044 { 00045 friend class factory<ParallelCompositeAggregator>; 00046 00047 // ----- constructors --------------------------------------------------- 00048 00049 protected: 00050 /** 00051 * Default constructor (necessary for the PortableObject 00052 * interface). 00053 */ 00054 ParallelCompositeAggregator(); 00055 00056 /** 00057 * Construct a ParallelCompositeAggregator based on a 00058 * specified 00059 * coherence::util::InvocableMap::EntryAggregator array. 00060 * 00061 * @param vaAggregator an array of ParallelAwareAggregator 00062 * objects; may not be null 00063 */ 00064 ParallelCompositeAggregator(ObjectArray::View vaAggregator); 00065 00066 private: 00067 /** 00068 * Blocked copy constructor. 00069 */ 00070 ParallelCompositeAggregator(const ParallelCompositeAggregator&); 00071 00072 00073 // ----- InvocableMap::ParallelAwareAggregator interface ---------------- 00074 00075 public: 00076 /** 00077 * {@inheritDoc} 00078 */ 00079 virtual InvocableMap::EntryAggregator::Handle 00080 getParallelAggregator(); 00081 00082 /** 00083 * {@inheritDoc} 00084 */ 00085 virtual Object::Holder aggregateResults( 00086 Collection::View vCollResults); 00087 }; 00088 00089 COH_CLOSE_NAMESPACE3 00090 00091 #endif // COH_PARALLEL_COMPOSITE_AGGREGATOR_HPP