|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
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.
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 |
---|
JobID getID()
@Deprecated String getJobID()
getID()
.
String getJobName()
String getJobFile()
String getTrackingURL()
float mapProgress() throws IOException
IOException
float reduceProgress() throws IOException
IOException
boolean isComplete() throws IOException
true
if the job is complete, else false
.
IOException
boolean isSuccessful() throws IOException
true
if the job succeeded, else false
.
IOException
void waitForCompletion() throws IOException
IOException
void killJob() throws IOException
IOException
TaskCompletionEvent[] getTaskCompletionEvents(int startFrom) throws IOException
startFrom
- index to start fetching events from
TaskCompletionEvent
s
IOException
void killTask(TaskAttemptID taskId, boolean shouldFail) throws IOException
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.
IOException
@Deprecated void killTask(String taskId, boolean shouldFail) throws IOException
killTask(TaskAttemptID, boolean)
IOException
Counters getCounters() throws IOException
IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |