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() |
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 . |
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.@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 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
Copyright © 2010 The Apache Software Foundation