org.apache.tez.mapreduce.hadoop
Class MRTaskStatus

java.lang.Object
  org.apache.tez.mapreduce.hadoop.MRTaskStatus

All Implemented Interfaces:

org.apache.hadoop.io.Writable, TezTaskStatus

public class MRTaskStatus
extends Object
implements TezTaskStatus

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.tez.common.TezTaskStatus

TezTaskStatus.Phase, TezTaskStatus.State

Constructor Summary

MRTaskStatus()

MRTaskStatus(org.apache.tez.dag.records.TezTaskAttemptID taskAttemptId, org.apache.tez.common.counters.TezCounters counters, TezTaskStatus.Phase phase)

Method Summary

void	addFailedDependency(org.apache.tez.dag.records.TezTaskAttemptID taskAttemptId)
void	clearStatus()
org.apache.tez.common.counters.TezCounters	getCounters()
String	getDiagnosticInfo()
List<org.apache.tez.dag.records.TezTaskAttemptID>	getFailedDependencies()
long	getFinishTime()
long	getLocalOutputSize()
long	getMapFinishTime()
TezTaskStatus.Phase	getPhase()
float	getProgress()
TezTaskStatus.State	getRunState()
long	getShuffleFinishTime()
long	getSortFinishTime()
long	getStartTime()
String	getStateString()
org.apache.tez.dag.records.TezTaskAttemptID	getTaskAttemptId()
void	readFields(DataInput in)
void	setCounters(org.apache.tez.common.counters.TezCounters counters)
void	setDiagnosticInfo(String info)
void	setFinishTime(long finishTime)
void	setMapFinishTime(long mapFinishTime)
void	setOutputSize(long localOutputSize)
void	setPhase(TezTaskStatus.Phase phase)
void	setProgress(float progress)
void	setRunState(TezTaskStatus.State state)
void	setShuffleFinishTime(long shuffleFinishTime)
void	setSortFinishTime(long sortFinishTime)
void	setStartTime(long startTime)
void	setStateString(String userStatusInfo)
void	statusUpdate(float progress, String userDiagnosticInfo, org.apache.tez.common.counters.TezCounters counters)
void	write(DataOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

MRTaskStatus

public MRTaskStatus()

MRTaskStatus

public MRTaskStatus(org.apache.tez.dag.records.TezTaskAttemptID taskAttemptId,
                    org.apache.tez.common.counters.TezCounters counters,
                    TezTaskStatus.Phase phase)

Method Detail

getTaskAttemptId

public org.apache.tez.dag.records.TezTaskAttemptID getTaskAttemptId()

Specified by:

getTaskAttemptId in interface TezTaskStatus

getProgress

public float getProgress()

Specified by:

getProgress in interface TezTaskStatus

setProgress

public void setProgress(float progress)

Specified by:

setProgress in interface TezTaskStatus

getRunState

public TezTaskStatus.State getRunState()

Specified by:

getRunState in interface TezTaskStatus

setRunState

public void setRunState(TezTaskStatus.State state)

Specified by:

setRunState in interface TezTaskStatus

getDiagnosticInfo

public String getDiagnosticInfo()

Specified by:

getDiagnosticInfo in interface TezTaskStatus

setDiagnosticInfo

public void setDiagnosticInfo(String info)

Specified by:

setDiagnosticInfo in interface TezTaskStatus

getStateString

public String getStateString()

Specified by:

getStateString in interface TezTaskStatus

setStateString

public void setStateString(String userStatusInfo)

Specified by:

setStateString in interface TezTaskStatus

getFinishTime

public long getFinishTime()

Specified by:

getFinishTime in interface TezTaskStatus

getShuffleFinishTime

public long getShuffleFinishTime()

Specified by:

getShuffleFinishTime in interface TezTaskStatus

getMapFinishTime

public long getMapFinishTime()

Specified by:

getMapFinishTime in interface TezTaskStatus

getSortFinishTime

public long getSortFinishTime()

Specified by:

getSortFinishTime in interface TezTaskStatus

getStartTime

public long getStartTime()

Specified by:

getStartTime in interface TezTaskStatus

getPhase

public TezTaskStatus.Phase getPhase()

Specified by:

getPhase in interface TezTaskStatus

setPhase

public void setPhase(TezTaskStatus.Phase phase)

Specified by:

setPhase in interface TezTaskStatus

getCounters

public org.apache.tez.common.counters.TezCounters getCounters()

Specified by:

getCounters in interface TezTaskStatus

setCounters

public void setCounters(org.apache.tez.common.counters.TezCounters counters)

Specified by:

setCounters in interface TezTaskStatus

getLocalOutputSize

public long getLocalOutputSize()

Specified by:

getLocalOutputSize in interface TezTaskStatus

getFailedDependencies

public List<org.apache.tez.dag.records.TezTaskAttemptID> getFailedDependencies()

Specified by:

getFailedDependencies in interface TezTaskStatus

addFailedDependency

public void addFailedDependency(org.apache.tez.dag.records.TezTaskAttemptID taskAttemptId)

Specified by:

addFailedDependency in interface TezTaskStatus

clearStatus

public void clearStatus()

Specified by:

clearStatus in interface TezTaskStatus

statusUpdate

public void statusUpdate(float progress,
                         String userDiagnosticInfo,
                         org.apache.tez.common.counters.TezCounters counters)

Specified by:

statusUpdate in interface TezTaskStatus

setOutputSize

public void setOutputSize(long localOutputSize)

Specified by:

setOutputSize in interface TezTaskStatus

setFinishTime

public void setFinishTime(long finishTime)

Specified by:

setFinishTime in interface TezTaskStatus

setShuffleFinishTime

public void setShuffleFinishTime(long shuffleFinishTime)

Specified by:

setShuffleFinishTime in interface TezTaskStatus

setMapFinishTime

public void setMapFinishTime(long mapFinishTime)

Specified by:

setMapFinishTime in interface TezTaskStatus

setSortFinishTime

public void setSortFinishTime(long sortFinishTime)

Specified by:

setSortFinishTime in interface TezTaskStatus

setStartTime

public void setStartTime(long startTime)

Specified by:

setStartTime in interface TezTaskStatus

write

public void write(DataOutput out)
           throws IOException

Specified by:

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

Throws:

IOException

readFields

public void readFields(DataInput in)
                throws IOException

Specified by:

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

Throws:

IOException