public static class JobHistory.MapAttempt extends JobHistory.TaskAttempt
Constructor and Description |
---|
JobHistory.MapAttempt() |
Modifier and Type | Method and Description |
---|---|
java.lang.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.
|
java.util.Map<JobHistory.Keys,java.lang.String> |
getValues()
Returns Map containing all key-values.
|
void |
handle(java.util.Map<JobHistory.Keys,java.lang.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,
java.lang.String hostName,
java.lang.String error)
Deprecated.
|
static void |
logFailed(TaskAttemptID taskAttemptId,
long timestamp,
java.lang.String hostName,
java.lang.String error,
java.lang.String taskType)
Log task attempt failed event.
|
static void |
logFinished(TaskAttemptID taskAttemptId,
long finishTime,
java.lang.String hostName)
|
static void |
logFinished(TaskAttemptID taskAttemptId,
long finishTime,
java.lang.String hostName,
java.lang.String taskType,
java.lang.String stateString,
Counters counter)
Log finish time of map task attempt.
|
static void |
logKilled(TaskAttemptID taskAttemptId,
long timestamp,
java.lang.String hostName,
java.lang.String error)
Deprecated.
|
static void |
logKilled(TaskAttemptID taskAttemptId,
long timestamp,
java.lang.String hostName,
java.lang.String error,
java.lang.String taskType)
Log task attempt killed event.
|
static void |
logStarted(TaskAttemptID taskAttemptId,
long startTime,
java.lang.String hostName)
Deprecated.
|
static void |
logStarted(TaskAttemptID taskAttemptId,
long startTime,
java.lang.String trackerName,
int httpPort,
java.lang.String taskType)
Log start time of this map task attempt.
|
void |
set(JobHistory.Keys k,
java.lang.String s)
Set value for the key.
|
void |
set(java.util.Map<JobHistory.Keys,java.lang.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, java.lang.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, java.lang.String trackerName, int httpPort, java.lang.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, java.lang.String hostName)
taskAttemptId
- task attempt idfinishTime
- finish timehostName
- host namepublic static void logFinished(TaskAttemptID taskAttemptId, long finishTime, java.lang.String hostName, java.lang.String taskType, java.lang.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, java.lang.String hostName, java.lang.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, java.lang.String hostName, java.lang.String error, java.lang.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, java.lang.String hostName, java.lang.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, java.lang.String hostName, java.lang.String error, java.lang.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 java.lang.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, java.lang.String s)
k
- s
- public void set(java.util.Map<JobHistory.Keys,java.lang.String> m)
m
- public void handle(java.util.Map<JobHistory.Keys,java.lang.String> values)
values
- public java.util.Map<JobHistory.Keys,java.lang.String> getValues()
Copyright © 2009 The Apache Software Foundation