Interface TaskAttemptReport
- All Known Implementing Classes:
TaskAttemptReportPBImpl
public interface TaskAttemptReport
-
Method Summary
Modifier and TypeMethodDescriptionorg.apache.hadoop.yarn.api.records.ContainerIdlongintintgetPhase()floatorg.apache.hadoop.mapreduce.CounterslonglonglongvoidsetContainerId(org.apache.hadoop.yarn.api.records.ContainerId containerId) voidsetCounters(Counters counters) voidsetDiagnosticInfo(String diagnosticInfo) voidsetFinishTime(long finishTime) voidsetNodeManagerHost(String nmHost) voidsetNodeManagerHttpPort(int nmHttpPort) voidsetNodeManagerPort(int nmPort) voidvoidsetProgress(float progress) voidsetRawCounters(org.apache.hadoop.mapreduce.Counters rCounters) voidsetShuffleFinishTime(long time) Set the shuffle finish time.voidsetSortFinishTime(long time) Set the sort/merge finish time.voidsetStartTime(long startTime) voidsetStateString(String stateString) voidsetTaskAttemptId(TaskAttemptId taskAttemptId) voidsetTaskAttemptState(TaskAttemptState taskAttemptState)
-
Method Details
-
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
-
setTaskAttemptState
-
setProgress
void setProgress(float progress) -
setStartTime
void setStartTime(long startTime) -
setFinishTime
void setFinishTime(long finishTime) -
setCounters
-
setRawCounters
void setRawCounters(org.apache.hadoop.mapreduce.Counters rCounters) -
setDiagnosticInfo
-
setStateString
-
setPhase
-
setNodeManagerHost
-
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.
-