|
||||||||||
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 | |
---|---|
float |
cleanupProgress()
Get the progress of the job's cleanup-tasks, as a float between 0.0 and 1.0. |
Counters |
getCounters()
Gets the counters for this job. |
JobID |
getID()
Get the job identifier. |
java.lang.String |
getJobFile()
Get the path of the submitted job configuration. |
java.lang.String |
getJobID()
Deprecated. This method is deprecated and will be removed. Applications should rather use getID() . |
java.lang.String |
getJobName()
Get the name of the job. |
int |
getJobState()
Returns the current state of the Job. |
TaskCompletionEvent[] |
getTaskCompletionEvents(int startFrom)
Get events indicating completion (success/failure) of component tasks. |
java.lang.String[] |
getTaskDiagnostics(TaskAttemptID taskid)
Gets the diagnostic messages for a given task attempt. |
java.lang.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(java.lang.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 |
setJobPriority(java.lang.String priority)
Set the priority of a running job. |
float |
setupProgress()
Get the progress of the job's setup-tasks, as a float between 0.0 and 1.0. |
void |
waitForCompletion()
Blocks until the job is complete. |
Method Detail |
---|
JobID getID()
@Deprecated java.lang.String getJobID()
getID()
.
java.lang.String getJobName()
java.lang.String getJobFile()
java.lang.String getTrackingURL()
float mapProgress() throws java.io.IOException
java.io.IOException
float reduceProgress() throws java.io.IOException
java.io.IOException
float cleanupProgress() throws java.io.IOException
java.io.IOException
float setupProgress() throws java.io.IOException
java.io.IOException
boolean isComplete() throws java.io.IOException
true
if the job is complete, else false
.
java.io.IOException
boolean isSuccessful() throws java.io.IOException
true
if the job succeeded, else false
.
java.io.IOException
void waitForCompletion() throws java.io.IOException
java.io.IOException
int getJobState() throws java.io.IOException
JobStatus
java.io.IOException
void killJob() throws java.io.IOException
java.io.IOException
void setJobPriority(java.lang.String priority) throws java.io.IOException
priority
- the new priority for the job.
java.io.IOException
TaskCompletionEvent[] getTaskCompletionEvents(int startFrom) throws java.io.IOException
startFrom
- index to start fetching events from
TaskCompletionEvent
s
java.io.IOException
void killTask(TaskAttemptID taskId, boolean shouldFail) throws java.io.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.
java.io.IOException
@Deprecated void killTask(java.lang.String taskId, boolean shouldFail) throws java.io.IOException
killTask(TaskAttemptID, boolean)
java.io.IOException
Counters getCounters() throws java.io.IOException
java.io.IOException
java.lang.String[] getTaskDiagnostics(TaskAttemptID taskid) throws java.io.IOException
taskid
-
java.io.IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |