| 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.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)
Deprecated.  
Defines the  
ReducerFactory for this task. | 
<ValueOut> ReducingSubmittableJob<EntryKey,KeyIn,ValueOut> | 
ReducingJob.reducer(ReducerFactory<KeyIn,ValueIn,ValueOut> reducerFactory)
Deprecated.  
Defines the  
ReducerFactory for this task. | 
| Modifier and Type | Method and Description | 
|---|---|
ReducerFactory | 
Aggregation.getReducerFactory()
Deprecated.  
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)  | 
| 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 © 2017 Hazelcast, Inc.. All Rights Reserved.