org.apache.tez.mapreduce.client

Class DAGJobStatus

java.lang.Object

org.apache.hadoop.mapreduce.JobStatus

org.apache.tez.mapreduce.client.DAGJobStatus

All Implemented Interfaces:

Cloneable, org.apache.hadoop.io.Writable

public class DAGJobStatus
extends org.apache.hadoop.mapreduce.JobStatus

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.JobStatus

org.apache.hadoop.mapreduce.JobStatus.State

Constructor Summary

Constructors

Constructor and Description
DAGJobStatus(org.apache.hadoop.yarn.api.records.ApplicationReport report, org.apache.tez.dag.api.client.DAGStatus dagStatus, String jobFile)

Method Summary

Methods

Modifier and Type	Method and Description
float	getCleanupProgress()
String	getFailureInfo()
long	getFinishTime()
String	getHistoryFile()
Map<org.apache.hadoop.mapreduce.JobACL,org.apache.hadoop.security.authorize.AccessControlList>	getJobACLs()
String	getJobFile()
org.apache.hadoop.mapreduce.JobID	getJobID()
String	getJobName()
float	getMapProgress()
int	getNeededMem()
int	getNumReservedSlots()
int	getNumUsedSlots()
org.apache.hadoop.mapreduce.JobPriority	getPriority()
String	getQueue()
float	getReduceProgress()
int	getReservedMem()
String	getSchedulingInfo()
float	getSetupProgress()
long	getStartTime()
org.apache.hadoop.mapreduce.JobStatus.State	getState()
String	getTrackingUrl()
int	getUsedMem()
String	getUsername()
boolean	isJobComplete()
boolean	isRetired()
boolean	isUber()
void	readFields(DataInput in)
protected void	setCleanupProgress(float p)
protected void	setFailureInfo(String failureInfo)
protected void	setFinishTime(long finishTime)
protected void	setHistoryFile(String historyFile)
protected void	setJobACLs(Map<org.apache.hadoop.mapreduce.JobACL,org.apache.hadoop.security.authorize.AccessControlList> acls)
protected void	setMapProgress(float p)
void	setNeededMem(int n)
void	setNumReservedSlots(int n)
void	setNumUsedSlots(int n)
protected void	setPriority(org.apache.hadoop.mapreduce.JobPriority jp)
protected void	setQueue(String queue)
protected void	setReduceProgress(float p)
void	setReservedMem(int r)
protected void	setRetired()
protected void	setSchedulingInfo(String schedulingInfo)
protected void	setSetupProgress(float p)
protected void	setStartTime(long startTime)
protected void	setState(org.apache.hadoop.mapreduce.JobStatus.State state)
protected void	setTrackingUrl(String trackingUrl)
void	setUber(boolean isUber)
void	setUsedMem(int m)
protected void	setUsername(String userName)
String	toString()
void	write(DataOutput out)

Methods inherited from class org.apache.hadoop.mapreduce.JobStatus

clone

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

DAGJobStatus

public DAGJobStatus(org.apache.hadoop.yarn.api.records.ApplicationReport report,
            org.apache.tez.dag.api.client.DAGStatus dagStatus,
            String jobFile)

Method Detail

setMapProgress

protected void setMapProgress(float p)

Overrides:

setMapProgress in class org.apache.hadoop.mapreduce.JobStatus

setCleanupProgress

protected void setCleanupProgress(float p)

Overrides:

setCleanupProgress in class org.apache.hadoop.mapreduce.JobStatus

setSetupProgress

protected void setSetupProgress(float p)

Overrides:

setSetupProgress in class org.apache.hadoop.mapreduce.JobStatus

setReduceProgress

protected void setReduceProgress(float p)

Overrides:

setReduceProgress in class org.apache.hadoop.mapreduce.JobStatus

setPriority

protected void setPriority(org.apache.hadoop.mapreduce.JobPriority jp)

Overrides:

setPriority in class org.apache.hadoop.mapreduce.JobStatus

setFinishTime

protected void setFinishTime(long finishTime)

Overrides:

setFinishTime in class org.apache.hadoop.mapreduce.JobStatus

setHistoryFile

protected void setHistoryFile(String historyFile)

Overrides:

setHistoryFile in class org.apache.hadoop.mapreduce.JobStatus

setTrackingUrl

protected void setTrackingUrl(String trackingUrl)

Overrides:

setTrackingUrl in class org.apache.hadoop.mapreduce.JobStatus

setRetired

protected void setRetired()

Overrides:

setRetired in class org.apache.hadoop.mapreduce.JobStatus

setState

protected void setState(org.apache.hadoop.mapreduce.JobStatus.State state)

Overrides:

setState in class org.apache.hadoop.mapreduce.JobStatus

setStartTime

protected void setStartTime(long startTime)

Overrides:

setStartTime in class org.apache.hadoop.mapreduce.JobStatus

setUsername

protected void setUsername(String userName)

Overrides:

setUsername in class org.apache.hadoop.mapreduce.JobStatus

setSchedulingInfo

protected void setSchedulingInfo(String schedulingInfo)

Overrides:

setSchedulingInfo in class org.apache.hadoop.mapreduce.JobStatus

setJobACLs

protected void setJobACLs(Map<org.apache.hadoop.mapreduce.JobACL,org.apache.hadoop.security.authorize.AccessControlList> acls)

Overrides:

setJobACLs in class org.apache.hadoop.mapreduce.JobStatus

setQueue

protected void setQueue(String queue)

Overrides:

setQueue in class org.apache.hadoop.mapreduce.JobStatus

setFailureInfo

protected void setFailureInfo(String failureInfo)

Overrides:

setFailureInfo in class org.apache.hadoop.mapreduce.JobStatus

getQueue

public String getQueue()

Overrides:

getQueue in class org.apache.hadoop.mapreduce.JobStatus

getMapProgress

public float getMapProgress()

Overrides:

getMapProgress in class org.apache.hadoop.mapreduce.JobStatus

getCleanupProgress

public float getCleanupProgress()

Overrides:

getCleanupProgress in class org.apache.hadoop.mapreduce.JobStatus

getSetupProgress

public float getSetupProgress()

Overrides:

getSetupProgress in class org.apache.hadoop.mapreduce.JobStatus

getReduceProgress

public float getReduceProgress()

Overrides:

getReduceProgress in class org.apache.hadoop.mapreduce.JobStatus

getState

public org.apache.hadoop.mapreduce.JobStatus.State getState()

Overrides:

getState in class org.apache.hadoop.mapreduce.JobStatus

getStartTime

public long getStartTime()

Overrides:

getStartTime in class org.apache.hadoop.mapreduce.JobStatus

getJobID

public org.apache.hadoop.mapreduce.JobID getJobID()

Overrides:

getJobID in class org.apache.hadoop.mapreduce.JobStatus

getUsername

public String getUsername()

Overrides:

getUsername in class org.apache.hadoop.mapreduce.JobStatus

getSchedulingInfo

public String getSchedulingInfo()

Overrides:

getSchedulingInfo in class org.apache.hadoop.mapreduce.JobStatus

getJobACLs

public Map<org.apache.hadoop.mapreduce.JobACL,org.apache.hadoop.security.authorize.AccessControlList> getJobACLs()

Overrides:

getJobACLs in class org.apache.hadoop.mapreduce.JobStatus

getPriority

public org.apache.hadoop.mapreduce.JobPriority getPriority()

Overrides:

getPriority in class org.apache.hadoop.mapreduce.JobStatus

getFailureInfo

public String getFailureInfo()

Overrides:

getFailureInfo in class org.apache.hadoop.mapreduce.JobStatus

isJobComplete

public boolean isJobComplete()

Overrides:

isJobComplete in class org.apache.hadoop.mapreduce.JobStatus

write

public void write(DataOutput out)
           throws IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Overrides:

write in class org.apache.hadoop.mapreduce.JobStatus

Throws:

IOException

readFields

public void readFields(DataInput in)
                throws IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Overrides:

readFields in class org.apache.hadoop.mapreduce.JobStatus

Throws:

IOException

getJobName

public String getJobName()

Overrides:

getJobName in class org.apache.hadoop.mapreduce.JobStatus

getJobFile

public String getJobFile()

Overrides:

getJobFile in class org.apache.hadoop.mapreduce.JobStatus

getTrackingUrl

public String getTrackingUrl()

Overrides:

getTrackingUrl in class org.apache.hadoop.mapreduce.JobStatus

getFinishTime

public long getFinishTime()

Overrides:

getFinishTime in class org.apache.hadoop.mapreduce.JobStatus

isRetired

public boolean isRetired()

Overrides:

isRetired in class org.apache.hadoop.mapreduce.JobStatus

getHistoryFile

public String getHistoryFile()

Overrides:

getHistoryFile in class org.apache.hadoop.mapreduce.JobStatus

getNumUsedSlots

public int getNumUsedSlots()

Overrides:

getNumUsedSlots in class org.apache.hadoop.mapreduce.JobStatus

setNumUsedSlots

public void setNumUsedSlots(int n)

Overrides:

setNumUsedSlots in class org.apache.hadoop.mapreduce.JobStatus

getNumReservedSlots

public int getNumReservedSlots()

Overrides:

getNumReservedSlots in class org.apache.hadoop.mapreduce.JobStatus

setNumReservedSlots

public void setNumReservedSlots(int n)

Overrides:

setNumReservedSlots in class org.apache.hadoop.mapreduce.JobStatus

getUsedMem

public int getUsedMem()

Overrides:

getUsedMem in class org.apache.hadoop.mapreduce.JobStatus

setUsedMem

public void setUsedMem(int m)

Overrides:

setUsedMem in class org.apache.hadoop.mapreduce.JobStatus

getReservedMem

public int getReservedMem()

Overrides:

getReservedMem in class org.apache.hadoop.mapreduce.JobStatus

setReservedMem

public void setReservedMem(int r)

Overrides:

setReservedMem in class org.apache.hadoop.mapreduce.JobStatus

getNeededMem

public int getNeededMem()

Overrides:

getNeededMem in class org.apache.hadoop.mapreduce.JobStatus

setNeededMem

public void setNeededMem(int n)

Overrides:

setNeededMem in class org.apache.hadoop.mapreduce.JobStatus

isUber

public boolean isUber()

Overrides:

isUber in class org.apache.hadoop.mapreduce.JobStatus

setUber

public void setUber(boolean isUber)

Overrides:

setUber in class org.apache.hadoop.mapreduce.JobStatus

toString

public String toString()

Overrides:

toString in class org.apache.hadoop.mapreduce.JobStatus