org.apache.hadoop.mapred
Class JobHistory.ReduceAttempt

java.lang.Object
  extended by org.apache.hadoop.mapred.JobHistory.Task
      extended by org.apache.hadoop.mapred.JobHistory.TaskAttempt
          extended by 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(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error)
          Deprecated. 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)
          Deprecated. 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)
          Deprecated. 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)
          Deprecated. Use logStarted(TaskAttemptID, long, String, int, String)
static void logStarted(TaskAttemptID taskAttemptId, long startTime, String trackerName, int httpPort, String taskType)
          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, logFailed, logFinished, logStarted, logUpdates
 
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

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

Log start time of Reduce task attempt.

Parameters:
taskAttemptId - task attempt id
startTime - start time
hostName - host name

logStarted

public static void logStarted(TaskAttemptID taskAttemptId,
                              long startTime,
                              String trackerName,
                              int httpPort,
                              String taskType)
Log start time of Reduce task attempt.

Parameters:
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

logFinished

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

Log finished event of this task.

Parameters:
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.

Parameters:
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)
Deprecated. Use logFailed(TaskAttemptID, long, String, String, String)

Log failed reduce task attempt.

Parameters:
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.

Parameters:
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)
Deprecated. Use logKilled(TaskAttemptID, long, String, String, String)

Log killed reduce task attempt.

Parameters:
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.

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

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.



Copyright © 2009 The Apache Software Foundation