| Package | Description | 
|---|---|
| com.hazelcast.mapreduce.impl | This package contains the default implementation for the map reduce framework
 internals. | 
| com.hazelcast.mapreduce.impl.task | This package contains the base implementation for a standard map reduce job. | 
| Modifier and Type | Method and Description | 
|---|---|
| JobSupervisor | MapReduceService. createJobSupervisor(JobTaskConfiguration configuration) | 
| JobSupervisor | MapReduceService. getJobSupervisor(String name,
                String jobId) | 
| Modifier and Type | Method and Description | 
|---|---|
| static JobProcessInformationImpl | MapReduceUtil. createJobProcessInformation(JobTaskConfiguration configuration,
                           JobSupervisor supervisor) | 
| boolean | MapReduceService. destroyJobSupervisor(JobSupervisor supervisor) | 
| static void | MapReduceUtil. notifyRemoteException(JobSupervisor supervisor,
                     Throwable throwable) | 
| Modifier and Type | Method and Description | 
|---|---|
| static <K,V> Map<Address,Map<K,V>> | MapCombineTask. mapResultToMember(JobSupervisor supervisor,
                 Map<K,V> result) | 
| Constructor and Description | 
|---|
| JobProcessInformationImpl(int partitionCount,
                         JobSupervisor supervisor) | 
| MapCombineTask(JobTaskConfiguration configuration,
              JobSupervisor supervisor,
              MappingPhase<KeyIn,ValueIn,KeyOut,ValueOut> mappingPhase) | 
| MemberAssigningJobProcessInformationImpl(int partitionCount,
                                        JobSupervisor supervisor) | 
| ReducerTask(String name,
           String jobId,
           JobSupervisor supervisor) | 
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.