|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.mapreduce.JobStatus org.apache.hadoop.mapred.JobStatus
@InterfaceAudience.Public @InterfaceStability.Stable 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)
Deprecated. |
|
JobStatus(JobID jobid,
float setupProgress,
float mapProgress,
float reduceProgress,
float cleanupProgress,
int runState,
JobPriority jp,
String user,
String jobName,
String jobFile,
String trackingUrl)
Create a job status object for a given jobid. |
|
JobStatus(JobID jobid,
float setupProgress,
float mapProgress,
float reduceProgress,
float cleanupProgress,
int runState,
JobPriority jp,
String user,
String jobName,
String jobFile,
String trackingUrl,
boolean isUber)
Create a job status object for a given jobid. |
|
JobStatus(JobID jobid,
float setupProgress,
float mapProgress,
float reduceProgress,
float cleanupProgress,
int runState,
JobPriority jp,
String user,
String jobName,
String queue,
String jobFile,
String trackingUrl)
Create a job status object for a given jobid. |
|
JobStatus(JobID jobid,
float setupProgress,
float mapProgress,
float reduceProgress,
float cleanupProgress,
int runState,
JobPriority jp,
String user,
String jobName,
String queue,
String jobFile,
String trackingUrl,
boolean isUber)
Create a job status object for a given jobid. |
|
JobStatus(JobID jobid,
float mapProgress,
float reduceProgress,
float cleanupProgress,
int runState)
Deprecated. |
|
JobStatus(JobID jobid,
float mapProgress,
float reduceProgress,
float cleanupProgress,
int runState,
JobPriority jp)
Deprecated. |
|
JobStatus(JobID jobid,
float mapProgress,
float reduceProgress,
float cleanupProgress,
int runState,
JobPriority jp,
String user,
String jobName,
String jobFile,
String trackingUrl)
Create a job status object for a given jobid. |
|
JobStatus(JobID jobid,
float mapProgress,
float reduceProgress,
float cleanupProgress,
int runState,
String user,
String jobName,
String jobFile,
String trackingUrl)
Create a job status object for a given jobid. |
|
JobStatus(JobID jobid,
float mapProgress,
float reduceProgress,
int runState)
Deprecated. |
|
JobStatus(JobID jobid,
float mapProgress,
float reduceProgress,
int runState,
String user,
String jobName,
String jobFile,
String trackingUrl)
Create a job status object for a given jobid. |
Method Summary | |
---|---|
float |
cleanupProgress()
|
static JobStatus |
downgrade(JobStatus stat)
|
String |
getJobId()
Deprecated. use getJobID instead |
JobID |
getJobID()
|
JobPriority |
getJobPriority()
Return the priority of the job |
static String |
getJobRunState(int state)
Helper method to get human-readable state of the job. |
int |
getRunState()
|
float |
mapProgress()
|
float |
reduceProgress()
|
protected void |
setCleanupProgress(float p)
Sets the cleanup progress of this job |
void |
setFailureInfo(String failureInfo)
Set diagnostic information. |
protected void |
setFinishTime(long finishTime)
Set the finish time of the job |
protected void |
setHistoryFile(String historyFile)
Set the job history file url for a completed job |
protected void |
setJobACLs(Map<org.apache.hadoop.mapreduce.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. |
protected void |
setMapProgress(float p)
Sets the map progress of this job |
protected void |
setReduceProgress(float p)
Sets the reduce progress of this Job |
protected void |
setRetired()
Set the job retire flag to true. |
protected void |
setSetupProgress(float p)
Sets the setup progress of this job |
protected void |
setStartTime(long startTime)
Set the start time of the job |
protected void |
setTrackingUrl(String trackingUrl)
Set the link to the web-ui for details of the job. |
float |
setupProgress()
|
protected void |
setUsername(String userName)
|
Methods inherited from class org.apache.hadoop.mapreduce.JobStatus |
---|
clone, getCleanupProgress, getFailureInfo, getFinishTime, getHistoryFile, getJobACLs, getJobFile, getJobName, getMapProgress, getNeededMem, getNumReservedSlots, getNumUsedSlots, getPriority, getQueue, getReduceProgress, getReservedMem, getSchedulingInfo, getSetupProgress, getStartTime, getState, getTrackingUrl, getUsedMem, getUsername, isJobComplete, isRetired, isUber, readFields, setNeededMem, setNumReservedSlots, setNumUsedSlots, setPriority, setQueue, setReservedMem, setState, setUber, setUsedMem, toString, write |
Methods inherited from class java.lang.Object |
---|
equals, finalize, getClass, hashCode, notify, notifyAll, 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()
@Deprecated public JobStatus(JobID jobid, float mapProgress, float reduceProgress, float cleanupProgress, int runState)
@Deprecated public 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 job@Deprecated public 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.@Deprecated 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 JobStatus(JobID jobid, float mapProgress, float reduceProgress, float cleanupProgress, int runState, String user, String jobName, String jobFile, String trackingUrl)
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 jobuser
- userid of the person who submitted the job.jobName
- user-specified job name.jobFile
- job configuration file.trackingUrl
- link to the web-ui for details of the job.public JobStatus(JobID jobid, float mapProgress, float reduceProgress, int runState, String user, String jobName, String jobFile, String trackingUrl)
jobid
- The jobid of the jobmapProgress
- The progress made on the mapsreduceProgress
- The progress made on the reducesrunState
- The current state of the jobuser
- userid of the person who submitted the job.jobName
- user-specified job name.jobFile
- job configuration file.trackingUrl
- link to the web-ui for details of the job.public JobStatus(JobID jobid, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp, String user, String jobName, String jobFile, String trackingUrl)
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.user
- userid of the person who submitted the job.jobName
- user-specified job name.jobFile
- job configuration file.trackingUrl
- link to the web-ui for details of the job.public JobStatus(JobID jobid, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp, String user, String jobName, String jobFile, String trackingUrl)
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.user
- userid of the person who submitted the job.jobName
- user-specified job name.jobFile
- job configuration file.trackingUrl
- link to the web-ui for details of the job.public JobStatus(JobID jobid, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp, String user, String jobName, String jobFile, String trackingUrl, boolean isUber)
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.user
- userid of the person who submitted the job.jobName
- user-specified job name.jobFile
- job configuration file.trackingUrl
- link to the web-ui for details of the job.isUber
- Whether job running in uber modepublic JobStatus(JobID jobid, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp, String user, String jobName, String queue, String jobFile, String trackingUrl)
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.user
- userid of the person who submitted the job.jobName
- user-specified job name.queue
- job queue name.jobFile
- job configuration file.trackingUrl
- link to the web-ui for details of the job.public JobStatus(JobID jobid, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp, String user, String jobName, String queue, String jobFile, String trackingUrl, boolean isUber)
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.user
- userid of the person who submitted the job.jobName
- user-specified job name.queue
- job queue name.jobFile
- job configuration file.trackingUrl
- link to the web-ui for details of the job.isUber
- Whether job running in uber modeMethod Detail |
---|
public static String getJobRunState(int state)
state
- job state
public static JobStatus downgrade(JobStatus stat)
@Deprecated public String getJobId()
public JobID getJobID()
getJobID
in class JobStatus
public JobPriority getJobPriority()
protected void setMapProgress(float p)
setMapProgress
in class JobStatus
p
- The value of map progress to set toprotected void setCleanupProgress(float p)
setCleanupProgress
in class JobStatus
p
- The value of cleanup progress to set toprotected void setSetupProgress(float p)
setSetupProgress
in class JobStatus
p
- The value of setup progress to set toprotected void setReduceProgress(float p)
setReduceProgress
in class JobStatus
p
- The value of reduce progress to set toprotected void setFinishTime(long finishTime)
setFinishTime
in class JobStatus
finishTime
- The finishTime of the jobprotected void setHistoryFile(String historyFile)
setHistoryFile
in class JobStatus
protected void setTrackingUrl(String trackingUrl)
setTrackingUrl
in class JobStatus
protected void setRetired()
setRetired
in class JobStatus
public int getRunState()
protected void setStartTime(long startTime)
setStartTime
in class JobStatus
startTime
- The startTime of the jobprotected void setUsername(String userName)
setUsername
in class JobStatus
userName
- The username of the jobprotected void setJobACLs(Map<org.apache.hadoop.mapreduce.JobACL,org.apache.hadoop.security.authorize.AccessControlList> acls)
JobStatus
setJobACLs
in class JobStatus
acls
- Map
from JobACL
to AccessControlList
public void setFailureInfo(String failureInfo)
JobStatus
setFailureInfo
in class JobStatus
failureInfo
- diagnostic informationpublic void setJobPriority(JobPriority jp)
jp
- new job prioritypublic float mapProgress()
public float cleanupProgress()
public float setupProgress()
public float reduceProgress()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |