org.apache.hadoop.mapred
Class JobHistory.ReduceAttempt

java.lang.Object
  org.apache.hadoop.mapred.JobHistory.Task
      org.apache.hadoop.mapred.JobHistory.TaskAttempt
          org.apache.hadoop.mapred.JobHistory.ReduceAttempt

Enclosing class:

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.

Constructor Summary

JobHistory.ReduceAttempt()

Method Summary

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(String jobId, String taskId, String taskAttemptId, long timestamp, String hostName, String error) Log failed reduce task attempt.
static void	logFinished(String jobId, String taskId, String taskAttemptId, long shuffleFinished, long sortFinished, long finishTime, String hostName) Log finished event of this task.
static void	logStarted(String jobId, String taskId, String taskAttemptId, long startTime, String hostName) 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.

Methods inherited from class org.apache.hadoop.mapred.JobHistory.Task

getTaskAttempts, logFailed, logFinished, logStarted

Methods inherited from class java.lang.Object

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

Constructor Detail

JobHistory.ReduceAttempt

public JobHistory.ReduceAttempt()

Method Detail

logStarted

public static void logStarted(String jobId,
                              String taskId,
                              String taskAttemptId,
                              long startTime,
                              String hostName)

Log start time of Reduce task attempt.

Parameters:

jobId - job id

taskId - task id (tip)

taskAttemptId - task attempt id

startTime - start time

hostName - host name

logFinished

public static void logFinished(String jobId,
                               String taskId,
                               String taskAttemptId,
                               long shuffleFinished,
                               long sortFinished,
                               long finishTime,
                               String hostName)

Log finished event of this task.

Parameters:

jobId - job id

taskId - task id

taskAttemptId - task attempt id

shuffleFinished - shuffle finish time

sortFinished - sort finish time

finishTime - finish time of task

hostName - host name where task attempt executed

logFailed

public static void logFailed(String jobId,
                             String taskId,
                             String taskAttemptId,
                             long timestamp,
                             String hostName,
                             String error)

Log failed reduce task attempt.

Parameters:

jobId - job id

taskId - task id

taskAttemptId - task attempt id

timestamp - time stamp when task failed

hostName - host name of the task attempt.

error - error message of the task.

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 ""

Parameters:

k -

Returns:

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.

Parameters:

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.

Parameters:

k -

set

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

Set value for the key.

Parameters:

k -

s -

set

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

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

Parameters:

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().

Parameters:

values -

getValues

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

Returns Map containing all key-values.