org.apache.hadoop.mapred
Interface RunningJob

public interface RunningJob

RunningJob is the user-interface to query for details on a running Map-Reduce job.

Clients can get hold of RunningJob via the JobClient and then query the running-job for details such as name, configuration, progress etc.

See Also:

JobClient

Method Summary

Counters	getCounters() Gets the counters for this job.
JobID	getID() Get the job identifier.
String	getJobFile() Get the path of the submitted job configuration.
String	getJobID() Deprecated. This method is deprecated and will be removed. Applications should rather use getID().
String	getJobName() Get the name of the job.
TaskCompletionEvent[]	getTaskCompletionEvents(int startFrom) Get events indicating completion (success/failure) of component tasks.
String	getTrackingURL() Get the URL where some job progress information will be displayed.
boolean	isComplete() Check if the job is finished or not.
boolean	isSuccessful() Check if the job completed successfully.
void	killJob() Kill the running job.
void	killTask(String taskId, boolean shouldFail) Deprecated. Applications should rather use killTask(TaskAttemptID, boolean)
void	killTask(TaskAttemptID taskId, boolean shouldFail) Kill indicated task attempt.
float	mapProgress() Get the progress of the job's map-tasks, as a float between 0.0 and 1.0.
float	reduceProgress() Get the progress of the job's reduce-tasks, as a float between 0.0 and 1.0.
void	waitForCompletion() Blocks until the job is complete.

Method Detail

getID

JobID getID()

Get the job identifier.

Returns:

the job identifier.

getJobID

@Deprecated
String getJobID()

Deprecated. This method is deprecated and will be removed. Applications should rather use getID().

getJobName

String getJobName()

Get the name of the job.

Returns:

the name of the job.

getJobFile

String getJobFile()

Get the path of the submitted job configuration.

Returns:

the path of the submitted job configuration.

getTrackingURL

String getTrackingURL()

Get the URL where some job progress information will be displayed.

Returns:

the URL where some job progress information will be displayed.

mapProgress

float mapProgress()
                  throws IOException

Get the progress of the job's map-tasks, as a float between 0.0 and 1.0. When all map tasks have completed, the function returns 1.0.

Returns:

the progress of the job's map-tasks.

Throws:

IOException

reduceProgress

float reduceProgress()
                     throws IOException

Get the progress of the job's reduce-tasks, as a float between 0.0 and 1.0. When all reduce tasks have completed, the function returns 1.0.

Returns:

the progress of the job's reduce-tasks.

Throws:

IOException

isComplete

boolean isComplete()
                   throws IOException

Check if the job is finished or not. This is a non-blocking call.

Returns:

true if the job is complete, else false.

Throws:

IOException

isSuccessful

boolean isSuccessful()
                     throws IOException

Check if the job completed successfully.

Returns:

true if the job succeeded, else false.

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

Get events indicating completion (success/failure) of component tasks.

Parameters:

startFrom - index to start fetching events from

Returns:

an array of TaskCompletionEvents

Throws:

IOException

killTask

void killTask(TaskAttemptID taskId,
              boolean shouldFail)
              throws IOException

Kill indicated task attempt.

Parameters:

taskId - the id of the task to be terminated.

shouldFail - if true the task is failed and added to failed tasks list, otherwise it is just killed, w/o affecting job failure status.

Throws:

IOException

killTask

@Deprecated
void killTask(String taskId,
                         boolean shouldFail)
              throws IOException

Deprecated. Applications should rather use killTask(TaskAttemptID, boolean)

Throws:

IOException

getCounters

Counters getCounters()
                     throws IOException

Gets the counters for this job.

Returns:

the counters for this job.

Throws:

IOException