org.apache.hadoop.mapred

类 JobHistory.ReduceAttempt

java.lang.Object

org.apache.hadoop.mapred.JobHistory.Task

org.apache.hadoop.mapred.JobHistory.TaskAttempt

org.apache.hadoop.mapred.JobHistory.ReduceAttempt

封闭类:

JobHistory

public static class JobHistory.ReduceAttempt
extends JobHistory.TaskAttempt

Helper class for logging or reading back events related to start, finish or failure of a Map Attempt on a node.

构造器概要

构造器

构造器和说明
JobHistory.ReduceAttempt()

方法概要

方法

限定符和类型	方法和说明
String	get(JobHistory.Keys k) Get 'String' value for given key.
int	getInt(JobHistory.Keys k) Convert value from history to int and return.
long	getLong(JobHistory.Keys k) Convert value from history to int and return.
Map<JobHistory.Keys,String>	getValues() Returns Map containing all key-values.
void	handle(Map<JobHistory.Keys,String> values) Reads values back from the history, input is same Map as passed to Listener by parseHistory().
static void	logFailed(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error) 已过时。 Use logFailed(TaskAttemptID, long, String, String, String)
static void	logFailed(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error, String taskType) Log failed reduce task attempt.
static void	logFinished(TaskAttemptID taskAttemptId, long shuffleFinished, long sortFinished, long finishTime, String hostName) 已过时。 Use logFinished(TaskAttemptID, long, long, long, String, String, String, Counters)
static void	logFinished(TaskAttemptID taskAttemptId, long shuffleFinished, long sortFinished, long finishTime, String hostName, String taskType, String stateString, Counters counter) Log finished event of this task.
static void	logKilled(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error) 已过时。 Use logKilled(TaskAttemptID, long, String, String, String)
static void	logKilled(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error, String taskType) Log killed reduce task attempt.
static void	logStarted(TaskAttemptID taskAttemptId, long startTime, String hostName) 已过时。 Use logStarted(TaskAttemptID, long, String, int, String)
static void	logStarted(TaskAttemptID taskAttemptId, long startTime, String trackerName, int httpPort, String taskType) 已过时。
static void	logStarted(TaskAttemptID taskAttemptId, long startTime, String trackerName, int httpPort, String taskType, org.apache.hadoop.mapred.Locality locality, org.apache.hadoop.mapred.Avataar avataar) Log start time of Reduce task attempt.
void	set(JobHistory.Keys k, String s) Set value for the key.
void	set(Map<JobHistory.Keys,String> m) Adds all values in the Map argument to its own values.

从类继承的方法 org.apache.hadoop.mapred.JobHistory.Task

getTaskAttempts, logFailed, logFailed, logFinished, logStarted, logUpdates

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

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

构造器详细资料

JobHistory.ReduceAttempt

public JobHistory.ReduceAttempt()

方法详细资料

logStarted

@Deprecated
public static void logStarted(TaskAttemptID taskAttemptId,
                         long startTime,
                         String hostName)

已过时。 Use logStarted(TaskAttemptID, long, String, int, String)

Log start time of Reduce task attempt.

参数:

taskAttemptId - task attempt id

startTime - start time

hostName - host name

logStarted

@Deprecated
public static void logStarted(TaskAttemptID taskAttemptId,
                         long startTime,
                         String trackerName,
                         int httpPort,
                         String taskType)

已过时。

logStarted

public static void logStarted(TaskAttemptID taskAttemptId,
              long startTime,
              String trackerName,
              int httpPort,
              String taskType,
              org.apache.hadoop.mapred.Locality locality,
              org.apache.hadoop.mapred.Avataar avataar)

Log start time of Reduce task attempt.

参数:

taskAttemptId - task attempt id

startTime - start time

trackerName - tracker name

httpPort - the http port of the tracker executing the task attempt

taskType - Whether the attempt is cleanup or setup or reduce

locality - the data locality of the task attempt

Avataar - the avataar of the task attempt

logFinished

@Deprecated
public static void logFinished(TaskAttemptID taskAttemptId,
                          long shuffleFinished,
                          long sortFinished,
                          long finishTime,
                          String hostName)

已过时。 Use logFinished(TaskAttemptID, long, long, long, String, String, String, Counters)

Log finished event of this task.

参数:

taskAttemptId - task attempt id

shuffleFinished - shuffle finish time

sortFinished - sort finish time

finishTime - finish time of task

hostName - host name where task attempt executed

logFinished

public static void logFinished(TaskAttemptID taskAttemptId,
               long shuffleFinished,
               long sortFinished,
               long finishTime,
               String hostName,
               String taskType,
               String stateString,
               Counters counter)

Log finished event of this task.

参数:

taskAttemptId - task attempt id

shuffleFinished - shuffle finish time

sortFinished - sort finish time

finishTime - finish time of task

hostName - host name where task attempt executed

taskType - Whether the attempt is cleanup or setup or reduce

stateString - the state string of the attempt

counter - counters of the attempt

logFailed

@Deprecated
public static void logFailed(TaskAttemptID taskAttemptId,
                        long timestamp,
                        String hostName,
                        String error)

已过时。 Use logFailed(TaskAttemptID, long, String, String, String)

Log failed reduce task attempt.

参数:

taskAttemptId - task attempt id

timestamp - time stamp when task failed

hostName - host name of the task attempt.

error - error message of the task.

logFailed

public static void logFailed(TaskAttemptID taskAttemptId,
             long timestamp,
             String hostName,
             String error,
             String taskType)

Log failed reduce task attempt.

参数:

taskAttemptId - task attempt id

timestamp - time stamp when task failed

hostName - host name of the task attempt.

error - error message of the task.

taskType - Whether the attempt is cleanup or setup or reduce

logKilled

@Deprecated
public static void logKilled(TaskAttemptID taskAttemptId,
                        long timestamp,
                        String hostName,
                        String error)

已过时。 Use logKilled(TaskAttemptID, long, String, String, String)

Log killed reduce task attempt.

参数:

taskAttemptId - task attempt id

timestamp - time stamp when task failed

hostName - host name of the task attempt.

error - error message of the task.

logKilled

public static void logKilled(TaskAttemptID taskAttemptId,
             long timestamp,
             String hostName,
             String error,
             String taskType)

Log killed reduce task attempt.

参数:

taskAttemptId - task attempt id

timestamp - time stamp when task failed

hostName - host name of the task attempt.

error - error message of the task.

taskType - Whether the attempt is cleanup or setup or reduce

get

public String get(JobHistory.Keys k)

Get 'String' value for given key. Most of the places use Strings as values so the default get' method returns 'String'. This method never returns null to ease on GUIs. if no value is found it returns empty string ""

参数:

k -

返回:

if null it returns empty string - ""

getInt

public int getInt(JobHistory.Keys k)

Convert value from history to int and return. if no value is found it returns 0.

参数:

k - key

getLong

public long getLong(JobHistory.Keys k)

Convert value from history to int and return. if no value is found it returns 0.

参数:

k -

set

public void set(JobHistory.Keys k,
       String s)

Set value for the key.

参数:

k -

s -

set

public void set(Map<JobHistory.Keys,String> m)

Adds all values in the Map argument to its own values.

参数:

m -

handle

public void handle(Map<JobHistory.Keys,String> values)

Reads values back from the history, input is same Map as passed to Listener by parseHistory().

参数:

values -

getValues

public Map<JobHistory.Keys,String> getValues()

Returns Map containing all key-values.