| 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 © 2022 Hazelcast, Inc.. All Rights Reserved.