|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use JobProcessInformation | |
---|---|
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 | |
---|---|
JobProcessInformation |
TrackableJob.getJobProcessInformation()
Returns an instance of JobProcessInformation to find out the state and
statistics of a running task or null if the underlying job id is not available because job is already
finished or not yet submitted.It even 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 | |
---|---|
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 | |
---|---|
JobProcessInformation |
TrackableJobFuture.getJobProcessInformation()
|
Methods in com.hazelcast.mapreduce.impl.task with parameters of type JobProcessInformation | |
---|---|
void |
JobSupervisor.checkFullyProcessed(JobProcessInformation processInformation)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |