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