Uses of Interface
com.hazelcast.mapreduce.JobPartitionState

Packages that use JobPartitionState

Package	Description
com.hazelcast.client.impl.protocol.codec	Client protocol custom codec implementations
com.hazelcast.client.impl.protocol.template
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.client.impl.protocol.codec

Methods in com.hazelcast.client.impl.protocol.codec that return JobPartitionState

Modifier and Type	Method and Description
static JobPartitionState	JobPartitionStateCodec.decode(ClientMessage clientMessage)

Methods in com.hazelcast.client.impl.protocol.codec with parameters of type JobPartitionState

Modifier and Type	Method and Description
static int	JobPartitionStateCodec.calculateDataSize(JobPartitionState jobPartitionState)
static void	JobPartitionStateCodec.encode(JobPartitionState jobPartitionState, ClientMessage clientMessage)

Uses of JobPartitionState in com.hazelcast.client.impl.protocol.template

Method parameters in com.hazelcast.client.impl.protocol.template with type arguments of type JobPartitionState

Modifier and Type	Method and Description
Object	ResponseTemplate.JobProcessInfo(List<JobPartitionState> jobPartitionStates, int processRecords)

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)