public class JobStatus
extends java.lang.Object
implements org.apache.hadoop.io.Writable, java.lang.Cloneable
for some more information.
Modifier and Type | Field and Description |
---|---|
static int |
FAILED |
static int |
KILLED |
static int |
PREP |
static int |
RUNNING |
static int |
SUCCEEDED |
Constructor and Description |
---|
JobStatus() |
JobStatus(JobID jobid,
float setupProgress,
float mapProgress,
float reduceProgress,
float cleanupProgress,
int runState,
JobPriority jp)
Create a job status object for a given jobid.
|
JobStatus(JobID jobid,
float mapProgress,
float reduceProgress,
float cleanupProgress,
int runState)
Create a job status object for a given jobid.
|
JobStatus(JobID jobid,
float mapProgress,
float reduceProgress,
float cleanupProgress,
int runState,
JobPriority jp)
Create a job status object for a given jobid.
|
JobStatus(JobID jobid,
float mapProgress,
float reduceProgress,
int runState)
Create a job status object for a given jobid.
|
Modifier and Type | Method and Description |
---|---|
float |
cleanupProgress() |
java.lang.Object |
clone() |
java.lang.String |
getFailureInfo()
gets any available info on the reason of failure of the job.
|
java.util.Map<JobACL,org.apache.hadoop.security.authorize.AccessControlList> |
getJobACLs()
Get the acls for Job.
|
java.lang.String |
getJobId()
Deprecated.
use getJobID instead
|
JobID |
getJobID() |
JobPriority |
getJobPriority()
Return the priority of the job
|
static java.lang.String |
getJobRunState(int state)
Helper method to get human-readable state of the job.
|
int |
getRunState() |
java.lang.String |
getSchedulingInfo()
Gets the Scheduling information associated to a particular Job.
|
long |
getStartTime() |
java.lang.String |
getUsername() |
boolean |
isJobComplete()
Returns true if the status is for a completed job.
|
float |
mapProgress() |
void |
readFields(java.io.DataInput in) |
float |
reduceProgress() |
void |
setFailureInfo(java.lang.String failureInfo)
set the reason for failuire of this job
|
protected void |
setJobACLs(java.util.Map<JobACL,org.apache.hadoop.security.authorize.AccessControlList> acls)
Set the job acls
|
void |
setJobPriority(JobPriority jp)
Set the priority of the job, defaulting to NORMAL.
|
void |
setRunState(int state)
Change the current run state of the job.
|
void |
setSchedulingInfo(java.lang.String schedulingInfo)
Used to set the scheduling information associated to a particular Job.
|
float |
setupProgress() |
void |
write(java.io.DataOutput out) |
public static final int RUNNING
public static final int SUCCEEDED
public static final int FAILED
public static final int PREP
public static final int KILLED
public JobStatus()
public JobStatus(JobID jobid, float mapProgress, float reduceProgress, float cleanupProgress, int runState)
jobid
- The jobid of the jobmapProgress
- The progress made on the mapsreduceProgress
- The progress made on the reducescleanupProgress
- The progress made on cleanuprunState
- The current state of the jobpublic JobStatus(JobID jobid, float mapProgress, float reduceProgress, int runState)
jobid
- The jobid of the jobmapProgress
- The progress made on the mapsreduceProgress
- The progress made on the reducesrunState
- The current state of the jobpublic JobStatus(JobID jobid, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp)
jobid
- The jobid of the jobmapProgress
- The progress made on the mapsreduceProgress
- The progress made on the reducesrunState
- The current state of the jobjp
- Priority of the job.public JobStatus(JobID jobid, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp)
jobid
- The jobid of the jobsetupProgress
- The progress made on the setupmapProgress
- The progress made on the mapsreduceProgress
- The progress made on the reducescleanupProgress
- The progress made on the cleanuprunState
- The current state of the jobjp
- Priority of the job.public static java.lang.String getJobRunState(int state)
state
- job state@Deprecated public java.lang.String getJobId()
public JobID getJobID()
public float mapProgress()
protected void setJobACLs(java.util.Map<JobACL,org.apache.hadoop.security.authorize.AccessControlList> acls)
acls
- Map
from JobACL
to AccessControlList
public float cleanupProgress()
public float setupProgress()
public float reduceProgress()
public int getRunState()
public void setRunState(int state)
public long getStartTime()
public java.lang.Object clone()
clone
in class java.lang.Object
public java.lang.String getUsername()
public java.lang.String getSchedulingInfo()
public java.lang.String getFailureInfo()
public void setFailureInfo(java.lang.String failureInfo)
failureInfo
- the reason for failure of this job.public void setSchedulingInfo(java.lang.String schedulingInfo)
schedulingInfo
- Scheduling information of the jobpublic java.util.Map<JobACL,org.apache.hadoop.security.authorize.AccessControlList> getJobACLs()
Map
from JobACL
to AccessControlList
public JobPriority getJobPriority()
public void setJobPriority(JobPriority jp)
jp
- new job prioritypublic boolean isJobComplete()
public void write(java.io.DataOutput out) throws java.io.IOException
write
in interface org.apache.hadoop.io.Writable
java.io.IOException
public void readFields(java.io.DataInput in) throws java.io.IOException
readFields
in interface org.apache.hadoop.io.Writable
java.io.IOException
Copyright © 2009 The Apache Software Foundation