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) |
Modifier and Type | Method and Description |
---|---|
static JobPartitionState.State |
MapReduceUtil.stateChange(Address owner,
int partitionId,
JobPartitionState.State currentState,
JobProcessInformationImpl processInformation,
JobTaskConfiguration configuration) |
Modifier and Type | Class and Description |
---|---|
class |
MemberAssigningJobProcessInformationImpl
This
JobProcessInformationImpl extending class is
used in non partitionId based map reduce tasks where partitions are kind of simulated using
a unique ID per member. |
Modifier and Type | Method and Description |
---|---|
JobProcessInformationImpl |
JobSupervisor.getJobProcessInformation() |
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.