org.apache.hadoop.mapreduce.v2.api.records

Interface TaskAttemptReport

All Known Implementing Classes:

TaskAttemptReportPBImpl

public interface TaskAttemptReport

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.yarn.api.records.ContainerId	getContainerId()
Counters	getCounters()
String	getDiagnosticInfo()
long	getFinishTime()
String	getNodeManagerHost()
int	getNodeManagerHttpPort()
int	getNodeManagerPort()
Phase	getPhase()
float	getProgress()
org.apache.hadoop.mapreduce.Counters	getRawCounters()
long	getShuffleFinishTime()
long	getSortFinishTime()
long	getStartTime()
String	getStateString()
TaskAttemptId	getTaskAttemptId()
TaskAttemptState	getTaskAttemptState()
void	setContainerId(org.apache.hadoop.yarn.api.records.ContainerId containerId)
void	setCounters(Counters counters)
void	setDiagnosticInfo(String diagnosticInfo)
void	setFinishTime(long finishTime)
void	setNodeManagerHost(String nmHost)
void	setNodeManagerHttpPort(int nmHttpPort)
void	setNodeManagerPort(int nmPort)
void	setPhase(Phase phase)
void	setProgress(float progress)
void	setRawCounters(org.apache.hadoop.mapreduce.Counters rCounters)
void	setShuffleFinishTime(long time) Set the shuffle finish time.
void	setSortFinishTime(long time) Set the sort/merge finish time.
void	setStartTime(long startTime)
void	setStateString(String stateString)
void	setTaskAttemptId(TaskAttemptId taskAttemptId)
void	setTaskAttemptState(TaskAttemptState taskAttemptState)

Method Detail

getTaskAttemptId

TaskAttemptId getTaskAttemptId()

getTaskAttemptState

TaskAttemptState getTaskAttemptState()

getProgress

float getProgress()

getStartTime

long getStartTime()

getFinishTime

long getFinishTime()

getShuffleFinishTime

long getShuffleFinishTime()

Returns:

the shuffle finish time. Applicable only for reduce attempts

getSortFinishTime

long getSortFinishTime()

Returns:

the sort/merge finish time. Applicable only for reduce attempts

getCounters

Counters getCounters()

getRawCounters

org.apache.hadoop.mapreduce.Counters getRawCounters()

getDiagnosticInfo

String getDiagnosticInfo()

getStateString

String getStateString()

getPhase

Phase getPhase()

getNodeManagerHost

String getNodeManagerHost()

getNodeManagerPort

int getNodeManagerPort()

getNodeManagerHttpPort

int getNodeManagerHttpPort()

getContainerId

org.apache.hadoop.yarn.api.records.ContainerId getContainerId()

setTaskAttemptId

void setTaskAttemptId(TaskAttemptId taskAttemptId)

setTaskAttemptState

void setTaskAttemptState(TaskAttemptState taskAttemptState)

setProgress

void setProgress(float progress)

setStartTime

void setStartTime(long startTime)

setFinishTime

void setFinishTime(long finishTime)

setCounters

void setCounters(Counters counters)

setRawCounters

void setRawCounters(org.apache.hadoop.mapreduce.Counters rCounters)

setDiagnosticInfo

void setDiagnosticInfo(String diagnosticInfo)

setStateString

void setStateString(String stateString)

setPhase

void setPhase(Phase phase)

setNodeManagerHost

void setNodeManagerHost(String nmHost)

setNodeManagerPort

void setNodeManagerPort(int nmPort)

setNodeManagerHttpPort

void setNodeManagerHttpPort(int nmHttpPort)

setContainerId

void setContainerId(org.apache.hadoop.yarn.api.records.ContainerId containerId)

setShuffleFinishTime

void setShuffleFinishTime(long time)

Set the shuffle finish time. Applicable only for reduce attempts

Parameters:

time - the time the shuffle finished.

setSortFinishTime

void setSortFinishTime(long time)

Set the sort/merge finish time. Applicable only for reduce attempts

Parameters:

time - the time the shuffle finished.