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 while processing.
To request the TrackableJob of a map reduce job, you can 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

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

Returns:

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