com.hazelcast.mapreduce

Interface TrackableJob<V>

Type Parameters:

V - type of the returning value

All Known Implementing Classes:

TrackableJobFuture

@Beta
public interface TrackableJob<V>

This interface describes a trackable job. In the default implementation the internal assigned operation processor is a TrackableJob so the process can be watched on while processing.
To request the TrackableJob of a map reduce job use the following code snippet

 JobTracker tracker = hazelcastInstance.getJobTracker(...);
 Job job = tracker.newJob(...);
 // ...
 JobCompletableFuture future = job.submit();
 String jobId = future.getJobId();
 TrackableJob trackableJob = tracker.getTrackableJob(jobId);
 

Since:

3.2

Method Summary

Methods

Modifier and Type	Method and Description
ICompletableFuture<V>	getCompletableFuture() Returns the ICompletableFuture to add callbacks or wait for the resulting value of the tracked job
String	getJobId() Returns the unique job id of the tracked job
JobProcessInformation	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.
JobTracker	getJobTracker() Returns the assigned JobTracker
String	getName() Returns the name of the underlying JobTracker

Method Detail

getJobTracker

JobTracker getJobTracker()

Returns the assigned JobTracker

Returns:

assigned JobTracker

getName

String getName()

Returns the name of the underlying JobTracker

Returns:

name of the JobTracker

getJobId

String getJobId()

Returns the unique job id of the tracked job

Returns:

job id of the tracked job

getCompletableFuture

ICompletableFuture<V> getCompletableFuture()

Returns the ICompletableFuture to add callbacks or wait for the resulting value of the tracked job

Returns:

ICompletableFuture of the tracked job

getJobProcessInformation

JobProcessInformation 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.

Returns:

instance of the jobs process information or null if job id is not available