|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.hadoop.mapred.JobStatus
public class JobStatus
Describes the current status of a job. This is not intended to be a comprehensive piece of data. For that, look at JobProfile.
Field Summary | |
---|---|
static int |
FAILED
|
static int |
KILLED
|
static int |
PREP
|
static int |
RUNNING
|
static int |
SUCCEEDED
|
Constructor Summary | |
---|---|
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. |
Method Summary | |
---|---|
float |
cleanupProgress()
|
Object |
clone()
|
String |
getJobId()
Deprecated. use getJobID instead |
JobID |
getJobID()
|
JobPriority |
getJobPriority()
Return the priority of the job |
int |
getRunState()
|
String |
getSchedulingInfo()
Gets the Scheduling information associated to a particular Job. |
long |
getStartTime()
|
String |
getUsername()
|
boolean |
isJobComplete()
Returns true if the status is for a completed job. |
float |
mapProgress()
|
void |
readFields(DataInput in)
Deserialize the fields of this object from in . |
float |
reduceProgress()
|
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(String schedulingInfo)
Used to set the scheduling information associated to a particular Job. |
float |
setupProgress()
|
void |
write(DataOutput out)
Serialize the fields of this object to out . |
Methods inherited from class java.lang.Object |
---|
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
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
Constructor Detail |
---|
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.Method Detail |
---|
@Deprecated public String getJobId()
public JobID getJobID()
public float mapProgress()
public float cleanupProgress()
public float setupProgress()
public float reduceProgress()
public int getRunState()
public void setRunState(int state)
public long getStartTime()
public Object clone()
clone
in class Object
public String getUsername()
public String getSchedulingInfo()
public void setSchedulingInfo(String schedulingInfo)
schedulingInfo
- Scheduling information of the jobpublic JobPriority getJobPriority()
public void setJobPriority(JobPriority jp)
jp
- new job prioritypublic boolean isJobComplete()
public void write(DataOutput out) throws IOException
Writable
out
.
write
in interface Writable
out
- DataOuput
to serialize this object into.
IOException
public void readFields(DataInput in) throws IOException
Writable
in
.
For efficiency, implementations should attempt to re-use storage in the existing object where possible.
readFields
in interface Writable
in
- DataInput
to deseriablize this object from.
IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |