org.apache.hadoop.mapred
Interface RunningJob

public interface RunningJob

Includes details on a running MapReduce job. A client can track a living job using this object.

Author:

Mike Cafarella

Method Summary

Counters	getCounters() Gets the counters for this job.
String	getJobFile() Returns the path of the submitted job.
String	getJobID() Returns an identifier for the job
TaskCompletionEvent[]	getTaskCompletionEvents(int startFrom)
String	getTrackingURL() Returns a URL where some job progress information will be displayed.
boolean	isComplete() Non-blocking function to check whether the job is finished or not.
boolean	isSuccessful() True iff job completed successfully.
void	killJob() Kill the running job.
float	mapProgress() Returns a float between 0.0 and 1.0, indicating progress on the map portion of the job.
float	reduceProgress() Returns a float between 0.0 and 1.0, indicating progress on the reduce portion of the job.
void	waitForCompletion() Blocks until the job is complete.

Method Detail

getJobID

String getJobID()

Returns an identifier for the job

getJobFile

String getJobFile()

Returns the path of the submitted job.

getTrackingURL

String getTrackingURL()

Returns a URL where some job progress information will be displayed.

mapProgress

float mapProgress()
                  throws IOException

Returns a float between 0.0 and 1.0, indicating progress on the map portion of the job. When all map tasks have completed, the function returns 1.0.

Throws:

IOException

reduceProgress

float reduceProgress()
                     throws IOException

Returns a float between 0.0 and 1.0, indicating progress on the reduce portion of the job. When all reduce tasks have completed, the function returns 1.0.

Throws:

IOException

isComplete

boolean isComplete()
                   throws IOException

Non-blocking function to check whether the job is finished or not.

Throws:

IOException

isSuccessful

boolean isSuccessful()
                     throws IOException

True iff job completed successfully.

Throws:

IOException

waitForCompletion

void waitForCompletion()
                       throws IOException

Blocks until the job is complete.

Throws:

IOException

killJob

void killJob()
             throws IOException

Kill the running job. Blocks until all job tasks have been killed as well. If the job is no longer running, it simply returns.

Throws:

IOException

getTaskCompletionEvents

TaskCompletionEvent[] getTaskCompletionEvents(int startFrom)
                                              throws IOException

Throws:

IOException

getCounters

Counters getCounters()
                     throws IOException

Gets the counters for this job.

Throws:

IOException