Uses of Interface
com.hazelcast.mapreduce.JobPartitionState

Packages that use JobPartitionState

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.

Uses of JobPartitionState in com.hazelcast.mapreduce

Methods in com.hazelcast.mapreduce that return JobPartitionState

Modifier and Type

Method and Description

JobPartitionState[]

JobProcessInformation.getPartitionStates() Returns an array of JobPartitionStates 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.

Uses of JobPartitionState in com.hazelcast.mapreduce.impl.task

Classes in com.hazelcast.mapreduce.impl.task that implement JobPartitionState

Modifier and Type	Class and Description
class	JobPartitionStateImpl This class holds information about the current processing state and the owner of a partition

Methods in com.hazelcast.mapreduce.impl.task that return JobPartitionState

Modifier and Type	Method and Description
JobPartitionState[]	JobProcessInformationImpl.getPartitionStates()
JobPartitionState[]	TransferableJobProcessInformation.getPartitionStates()

Methods in com.hazelcast.mapreduce.impl.task with parameters of type JobPartitionState

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)

Constructors in com.hazelcast.mapreduce.impl.task with parameters of type JobPartitionState

Constructor and Description
TransferableJobProcessInformation(JobPartitionState[] partitionStates, int processedRecords)