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