| 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 | 
|---|---|
static JobProcessInformationImpl | 
MapReduceUtil.createJobProcessInformation(JobTaskConfiguration configuration,
                           JobSupervisor supervisor)  | 
JobSupervisor | 
MapReduceService.createJobSupervisor(JobTaskConfiguration configuration)  | 
static JobPartitionState.State | 
MapReduceUtil.stateChange(Address owner,
           int partitionId,
           JobPartitionState.State currentState,
           JobProcessInformationImpl processInformation,
           JobTaskConfiguration configuration)  | 
| Modifier and Type | Method and Description | 
|---|---|
JobTaskConfiguration | 
JobSupervisor.getConfiguration()  | 
| Modifier and Type | Method and Description | 
|---|---|
int | 
MemberAssigningJobProcessInformationImpl.assignMemberId(Address address,
              String memberUuid,
              JobTaskConfiguration configuration)  | 
| Constructor and Description | 
|---|
JobSupervisor(JobTaskConfiguration configuration,
             AbstractJobTracker jobTracker,
             boolean ownerNode,
             MapReduceService mapReduceService)  | 
MapCombineTask(JobTaskConfiguration configuration,
              JobSupervisor supervisor,
              MappingPhase<KeyIn,ValueIn,KeyOut,ValueOut> mappingPhase)  | 
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.