org.apache.tez.common
Interface TezTaskStatus

All Superinterfaces:

org.apache.hadoop.io.Writable

All Known Implementing Classes:

MRTaskStatus

public interface TezTaskStatus
extends org.apache.hadoop.io.Writable

Nested Class Summary

static class	TezTaskStatus.Phase
static class	TezTaskStatus.State

Method Summary

void	addFailedDependency(org.apache.tez.dag.records.TezTaskAttemptID taskAttempttId)
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	setCounters(org.apache.tez.common.counters.TezCounters counters)
void	setDiagnosticInfo(String info)
void	setFinishTime(long finishTime)
void	setMapFinishTime(long mapFinishTime)
void	setOutputSize(long l)
void	setPhase(TezTaskStatus.Phase phase)
void	setProgress(float progress)
void	setRunState(TezTaskStatus.State runState)
void	setShuffleFinishTime(long shuffleFinishTime)
void	setSortFinishTime(long sortFinishTime)
void	setStartTime(long startTime)
void	setStateString(String stateString)
void	statusUpdate(float f, String string, org.apache.tez.common.counters.TezCounters counters)

Methods inherited from interface org.apache.hadoop.io.Writable

readFields, write

Method Detail

getTaskAttemptId

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

getProgress

float getProgress()

setProgress

void setProgress(float progress)

getRunState

TezTaskStatus.State getRunState()

setRunState

void setRunState(TezTaskStatus.State runState)

getDiagnosticInfo

String getDiagnosticInfo()

setDiagnosticInfo

void setDiagnosticInfo(String info)

getStateString

String getStateString()

setStateString

void setStateString(String stateString)

getFinishTime

long getFinishTime()

setFinishTime

void setFinishTime(long finishTime)

getShuffleFinishTime

long getShuffleFinishTime()

setShuffleFinishTime

void setShuffleFinishTime(long shuffleFinishTime)

getMapFinishTime

long getMapFinishTime()

setMapFinishTime

void setMapFinishTime(long mapFinishTime)

getSortFinishTime

long getSortFinishTime()

setSortFinishTime

void setSortFinishTime(long sortFinishTime)

getStartTime

long getStartTime()

setStartTime

void setStartTime(long startTime)

getPhase

TezTaskStatus.Phase getPhase()

setPhase

void setPhase(TezTaskStatus.Phase phase)

getCounters

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

setCounters

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

getFailedDependencies

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

addFailedDependency

void addFailedDependency(org.apache.tez.dag.records.TezTaskAttemptID taskAttempttId)

clearStatus

void clearStatus()

statusUpdate

void statusUpdate(float f,
                  String string,
                  org.apache.tez.common.counters.TezCounters counters)

getLocalOutputSize

long getLocalOutputSize()

setOutputSize

void setOutputSize(long l)