| Package | Description | 
|---|---|
| com.hazelcast.client.impl.protocol.task.mapreduce | Client protocol tasks implementations for map reduce | 
| com.hazelcast.mapreduce | This package contains the MapReduce API definition for Hazelcast. All map reduce operations running in a distributed manner inside the active Hazelcast cluster. | 
| com.hazelcast.mapreduce.aggregation | This package contains the aggregation API and the convenience helper classes
 to retrieve predefined aggregation implementations. | 
| com.hazelcast.mapreduce.aggregation.impl | This package contains a set of predefined aggregation implementations | 
| com.hazelcast.mapreduce.impl | This package contains the default implementation for the map reduce framework
 internals. | 
| com.hazelcast.mapreduce.impl.client | This package contains request and response classes for communication between cluster
 members and Hazelcast native clients | 
| com.hazelcast.mapreduce.impl.operation | This package contains all remote operations that are needed to control work on
 supervising or worker nodes. | 
| com.hazelcast.mapreduce.impl.task | This package contains the base implementation for a standard map reduce job. | 
| Modifier and Type | Method and Description | 
|---|---|
| protected ReducerFactory | MapReduceForMapMessageTask. getReducerFactory() | 
| protected ReducerFactory | MapReduceForSetMessageTask. getReducerFactory() | 
| protected abstract ReducerFactory | AbstractMapReduceTask. getReducerFactory() | 
| protected ReducerFactory | MapReduceForCustomMessageTask. getReducerFactory() | 
| protected ReducerFactory | MapReduceForListMessageTask. getReducerFactory() | 
| protected ReducerFactory | MapReduceForMultiMapMessageTask. getReducerFactory() | 
| Modifier and Type | Method and Description | 
|---|---|
| <ValueOut> ReducingSubmittableJob<EntryKey,KeyIn,ValueOut> | MappingJob. reducer(ReducerFactory<? super KeyIn,? super ValueIn,? extends ValueOut> reducerFactory)Defines the  ReducerFactoryfor this task. | 
| <ValueOut> ReducingSubmittableJob<EntryKey,KeyIn,ValueOut> | ReducingJob. reducer(ReducerFactory<KeyIn,ValueIn,ValueOut> reducerFactory)Defines the  ReducerFactoryfor this task. | 
| Modifier and Type | Method and Description | 
|---|---|
| ReducerFactory | Aggregation. getReducerFactory()Returns the ReducerFactory for this aggregation. | 
| Modifier and Type | Field and Description | 
|---|---|
| protected ReducerFactory<?,?,?> | AbstractJob. reducerFactory | 
| Modifier and Type | Method and Description | 
|---|---|
| <ValueOut> ReducingSubmittableJob<EntryKey,Key,ValueOut> | AbstractJob.MappingJobImpl. reducer(ReducerFactory<? super Key,? super Value,? extends ValueOut> reducerFactory) | 
| <ValueOut> ReducingSubmittableJob<EntryKey,Key,ValueOut> | AbstractJob.ReducingJobImpl. reducer(ReducerFactory<Key,Value,ValueOut> reducerFactory) | 
| Modifier and Type | Field and Description | 
|---|---|
| protected ReducerFactory | ClientMapReduceRequest. reducerFactory | 
| Constructor and Description | 
|---|
| ClientMapReduceRequest(String name,
                      String jobId,
                      Collection keys,
                      KeyPredicate predicate,
                      Mapper mapper,
                      CombinerFactory combinerFactory,
                      ReducerFactory reducerFactory,
                      KeyValueSource keyValueSource,
                      int chunkSize,
                      TopologyChangedStrategy topologyChangedStrategy) | 
| Constructor and Description | 
|---|
| KeyValueJobOperation(String name,
                    String jobId,
                    int chunkSize,
                    KeyValueSource<K,V> keyValueSource,
                    Mapper mapper,
                    CombinerFactory combinerFactory,
                    ReducerFactory reducerFactory,
                    boolean communicateStats,
                    TopologyChangedStrategy topologyChangedStrategy) | 
| Modifier and Type | Method and Description | 
|---|---|
| ReducerFactory | JobTaskConfiguration. getReducerFactory() | 
| Constructor and Description | 
|---|
| JobTaskConfiguration(Address jobOwner,
                    NodeEngine nodeEngine,
                    int chunkSize,
                    String name,
                    String jobId,
                    Mapper mapper,
                    CombinerFactory combinerFactory,
                    ReducerFactory reducerFactory,
                    KeyValueSource keyValueSource,
                    boolean communicateStats,
                    TopologyChangedStrategy topologyChangedStrategy) | 
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.