Uses of Interface
com.hazelcast.mapreduce.JobProcessInformation

Packages that use JobProcessInformation

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 JobProcessInformation in com.hazelcast.mapreduce

Methods in com.hazelcast.mapreduce that return JobProcessInformation

Modifier and Type

Method and Description

JobProcessInformation

TrackableJob.getJobProcessInformation() Returns an instance of JobProcessInformation to find out the state and statistics of a running task, or returns null if the underlying job id is not available because the job is already finished or has not yet been submitted. It returns null if not requested on the job issuing cluster member or client, since those values are not distributed to all clusters for traffic reasons.

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

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

Modifier and Type	Class and Description
class	JobProcessInformationImpl This class controls all partition states and is capable of atomically updating those states.
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.
class	TransferableJobProcessInformation This implementation of JobProcessInformation is used to transmit the currently processed number of records and the partition states to a requesting client.

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

Modifier and Type	Method and Description
JobProcessInformation	TrackableJobFuture.getJobProcessInformation()

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

Modifier and Type	Method and Description
void	JobSupervisor.checkFullyProcessed(JobProcessInformation processInformation)