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)
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.
|
Modifier and Type | Method and Description |
---|---|
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,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) |
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
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()
@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 modepublic static String getJobRunState(int state)
state
- job state@Deprecated public String getJobId()
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,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()
Copyright © 2015 Apache Software Foundation. All rights reserved.