org.apache.hadoop.tools.rumen

类 ParsedTaskAttempt

java.lang.Object

org.apache.hadoop.tools.rumen.LoggedTaskAttempt

org.apache.hadoop.tools.rumen.ParsedTaskAttempt

所有已实现的接口:

DeepCompare

public class ParsedTaskAttempt
extends LoggedTaskAttempt

This is a wrapper class around LoggedTaskAttempt. This provides also the extra information about the task attempt obtained from job history which is not written to the JSON trace file.

方法概要

方法

限定符和类型	方法和说明
void	incorporateCounters(JhCounters counters) incorporate event counters
Map<String,Long>	obtainCounters()
String	obtainDiagnosticInfo()
Integer	obtainHttpPort()
String	obtainStateString()
String	obtainTrackerName()
void	putCounters(Map<String,Long> counters) Set the task attempt counters
void	putDiagnosticInfo(String msg) Set the task attempt diagnostic-info

从类继承的方法 org.apache.hadoop.tools.rumen.LoggedTaskAttempt

deepCompare, getAttemptID, getCombineInputRecords, getFileBytesRead, getFileBytesWritten, getFinishTime, getHdfsBytesRead, getHdfsBytesWritten, getHostName, getLocation, getMapInputBytes, getMapInputRecords, getMapOutputBytes, getMapOutputRecords, getReduceInputGroups, getReduceInputRecords, getReduceOutputRecords, getReduceShuffleBytes, getResourceUsageMetrics, getResult, getShuffleFinished, getSortFinished, getSpilledRecords, getStartTime, setUnknownAttribute

从类继承的方法 java.lang.Object

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

方法详细资料

incorporateCounters

public void incorporateCounters(JhCounters counters)

incorporate event counters

覆盖:

incorporateCounters 在类中 LoggedTaskAttempt

putCounters

public void putCounters(Map<String,Long> counters)

Set the task attempt counters

obtainCounters

public Map<String,Long> obtainCounters()

返回:

the task attempt counters

putDiagnosticInfo

public void putDiagnosticInfo(String msg)

Set the task attempt diagnostic-info

obtainDiagnosticInfo

public String obtainDiagnosticInfo()

返回:

the diagnostic-info of this task attempt. If the attempt is successful, returns null.

obtainTrackerName

public String obtainTrackerName()

返回:

the tracker name where the attempt was run.

obtainHttpPort

public Integer obtainHttpPort()

返回:

http port if set. Returns null otherwise.

obtainStateString

public String obtainStateString()

返回:

state string of the task attempt.