| Package | Description |
|---|---|
| com.hazelcast.mapreduce |
This package contains the MapReduce API definition for Hazelcast.
All map reduce operations running in a distributed manner inside the active Hazelcast cluster. |
| com.hazelcast.mapreduce.impl |
This package contains the default implementation for the map reduce framework
internals.
|
| com.hazelcast.mapreduce.impl.operation |
This package contains all remote operations that are needed to control work on
supervising or worker nodes.
|
| com.hazelcast.mapreduce.impl.task |
This package contains the base implementation for a standard map reduce job.
|
| Modifier and Type | Method and Description |
|---|---|
static JobPartitionState.State |
JobPartitionState.State.byOrdinal(int ordinal)
Returns an processing state by its given ordinal
|
JobPartitionState.State |
JobPartitionState.getState()
Returns the current processing state of this partition
|
static JobPartitionState.State |
JobPartitionState.State.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static JobPartitionState.State[] |
JobPartitionState.State.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
| 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 | Method and Description |
|---|---|
static JobPartitionState.State |
MapReduceUtil.stateChange(Address owner,
int partitionId,
JobPartitionState.State currentState,
JobProcessInformationImpl processInformation,
JobTaskConfiguration configuration) |
| Constructor and Description |
|---|
RequestPartitionProcessed(String name,
String jobId,
int partitionId,
JobPartitionState.State currentState) |
| Modifier and Type | Method and Description |
|---|---|
JobPartitionState.State |
JobPartitionStateImpl.getState() |
| Constructor and Description |
|---|
JobPartitionStateImpl(Address address,
JobPartitionState.State state) |
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.