org.apache.hadoop.tools.rumen

类 ParsedTask

java.lang.Object

org.apache.hadoop.tools.rumen.LoggedTask

org.apache.hadoop.tools.rumen.ParsedTask

所有已实现的接口:

DeepCompare

public class ParsedTask
extends LoggedTask

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

方法概要

方法

限定符和类型	方法和说明
void	incorporateCounters(JhCounters counters)
Map<String,Long>	obtainCounters()
String	obtainDiagnosticInfo()
String	obtainFailedDueToAttemptId()
List<ParsedTaskAttempt>	obtainTaskAttempts()
void	putCounters(Map<String,Long> counters) Set the task counters
void	putDiagnosticInfo(String msg) Set the task diagnostic-info
void	putFailedDueToAttemptId(String attempt) Set the failed-due-to-attemptId info of this task.

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

deepCompare, getAttempts, getFinishTime, getInputBytes, getInputRecords, getOutputBytes, getOutputRecords, getPreferredLocations, getStartTime, getTaskID, getTaskStatus, getTaskType, setUnknownAttribute

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

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

方法详细资料

incorporateCounters

public void incorporateCounters(JhCounters counters)

覆盖:

incorporateCounters 在类中 LoggedTask

putCounters

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

Set the task counters

obtainCounters

public Map<String,Long> obtainCounters()

返回:

the task counters

putDiagnosticInfo

public void putDiagnosticInfo(String msg)

Set the task diagnostic-info

obtainDiagnosticInfo

public String obtainDiagnosticInfo()

返回:

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

putFailedDueToAttemptId

public void putFailedDueToAttemptId(String attempt)

Set the failed-due-to-attemptId info of this task.

obtainFailedDueToAttemptId

public String obtainFailedDueToAttemptId()

返回:

the failed-due-to-attemptId info of this task. If the task is successful, returns null.

obtainTaskAttempts

public List<ParsedTaskAttempt> obtainTaskAttempts()