public static class JobHistory.MapAttempt extends JobHistory.TaskAttempt
Constructor and Description |
---|
MapAttempt() |
Modifier and Type | Method and Description |
---|---|
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.
|
static void |
logFailed(TaskAttemptID taskAttemptId,
long timestamp,
String hostName,
String error,
String taskType)
Log task attempt failed event.
|
static void |
logFinished(TaskAttemptID taskAttemptId,
long finishTime,
String hostName)
|
static void |
logFinished(TaskAttemptID taskAttemptId,
long finishTime,
String hostName,
String taskType,
String stateString,
Counters counter)
Log finish time of map task attempt.
|
static void |
logKilled(TaskAttemptID taskAttemptId,
long timestamp,
String hostName,
String error)
Deprecated.
|
static void |
logKilled(TaskAttemptID taskAttemptId,
long timestamp,
String hostName,
String error,
String taskType)
Log task attempt killed event.
|
static void |
logStarted(TaskAttemptID taskAttemptId,
long startTime,
String hostName)
Deprecated.
|
static void |
logStarted(TaskAttemptID taskAttemptId,
long startTime,
String trackerName,
int httpPort,
String taskType)
Log start time of this map 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.
|
getTaskAttempts, logFailed, logFailed, logFinished, logStarted, logUpdates
@Deprecated public static void logStarted(TaskAttemptID taskAttemptId, long startTime, String hostName)
logStarted(TaskAttemptID, long, String, int, String)
taskAttemptId
- task attempt idstartTime
- start time of task attempt as reported by task tracker.hostName
- host name of the task attempt.public static void logStarted(TaskAttemptID taskAttemptId, long startTime, String trackerName, int httpPort, String taskType)
taskAttemptId
- task attempt idstartTime
- start time of task attempt as reported by task tracker.trackerName
- name of the tracker executing the task attempt.httpPort
- http port of the task tracker executing the task attempttaskType
- Whether the attempt is cleanup or setup or map@Deprecated public static void logFinished(TaskAttemptID taskAttemptId, long finishTime, String hostName)
taskAttemptId
- task attempt idfinishTime
- finish timehostName
- host namepublic static void logFinished(TaskAttemptID taskAttemptId, long finishTime, String hostName, String taskType, String stateString, Counters counter)
taskAttemptId
- task attempt idfinishTime
- finish timehostName
- host nametaskType
- Whether the attempt is cleanup or setup or mapstateString
- state string of the task attemptcounter
- counters of the task attempt@Deprecated public static void logFailed(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error)
logFailed(TaskAttemptID, long, String, String, String)
taskAttemptId
- task attempt idtimestamp
- timestamphostName
- hostname of this task attempt.error
- error message if any for this task attempt.public static void logFailed(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error, String taskType)
taskAttemptId
- task attempt idtimestamp
- timestamphostName
- hostname of this task attempt.error
- error message if any for this task attempt.taskType
- Whether the attempt is cleanup or setup or map@Deprecated public static void logKilled(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error)
logKilled(TaskAttemptID, long, String, String, String)
taskAttemptId
- task attempt idtimestamp
- timestamphostName
- hostname of this task attempt.error
- error message if any for this task attempt.public static void logKilled(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error, String taskType)
taskAttemptId
- task attempt idtimestamp
- timestamphostName
- hostname of this task attempt.error
- error message if any for this task attempt.taskType
- Whether the attempt is cleanup or setup or mappublic String get(JobHistory.Keys k)
k
- public int getInt(JobHistory.Keys k)
k
- keypublic long getLong(JobHistory.Keys k)
k
- public void set(JobHistory.Keys k, String s)
k
- s
- public void set(Map<JobHistory.Keys,String> m)
m
- public void handle(Map<JobHistory.Keys,String> values)
values
- public Map<JobHistory.Keys,String> getValues()
Copyright © 2010 The Apache Software Foundation