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.task |
This package contains the base implementation for a standard map reduce job.
|
Modifier and Type | Method and Description |
---|---|
JobPartitionState[] |
JobProcessInformation.getPartitionStates()
Deprecated.
Returns an array of
JobPartitionState s holding
information about the processing state (JobPartitionState.State )
and the processing owner of this partition.The index of the JobPartitionState inside of the
array is the number of the processed partition if the KeyValueSource
is PartitionIdAware or a randomly assigned ID for
the different members of the cluster. |
Modifier and Type | Class and Description |
---|---|
class |
JobPartitionStateImpl
This class holds information about the current processing state and the owner of a partition.
|
Modifier and Type | Method and Description |
---|---|
JobPartitionState[] |
JobProcessInformationImpl.getPartitionStates() |
JobPartitionState[] |
TransferableJobProcessInformation.getPartitionStates() |
Modifier and Type | Method and Description |
---|---|
boolean |
JobProcessInformationImpl.updatePartitionState(int partitionId,
JobPartitionState oldPartitionState,
JobPartitionState newPartitionState) |
boolean |
JobProcessInformationImpl.updatePartitionState(JobPartitionState[] oldPartitionStates,
JobPartitionState[] newPartitionStates) |
boolean |
JobProcessInformationImpl.updatePartitionState(JobPartitionState[] oldPartitionStates,
JobPartitionState[] newPartitionStates) |
Constructor and Description |
---|
TransferableJobProcessInformation(JobPartitionState[] partitionStates,
int processedRecords) |
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.