|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.mapred.JobHistory.Task org.apache.hadoop.mapred.JobHistory.TaskAttempt org.apache.hadoop.mapred.JobHistory.ReduceAttempt
public static class JobHistory.ReduceAttempt
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 attemptid,
long timestamp,
String hostname,
String error)
Deprecated. |
static void |
logFailed(TaskAttemptID taskAttemptId,
long timestamp,
String hostName,
String error)
Log failed reduce task attempt. |
static void |
logFinished(String jobid,
String taskid,
String attemptid,
long shuffleFinished,
long sortFinished,
long finishTime,
String hostname)
Deprecated. |
static void |
logFinished(TaskAttemptID taskAttemptId,
long shuffleFinished,
long sortFinished,
long finishTime,
String hostName)
Log finished event of this task. |
static void |
logKilled(String jobid,
String taskid,
String attemptid,
long timestamp,
String hostname,
String error)
Deprecated. |
static void |
logKilled(TaskAttemptID taskAttemptId,
long timestamp,
String hostName,
String error)
Log killed reduce task attempt. |
static void |
logStarted(String jobid,
String taskid,
String attemptid,
long startTime,
String hostName)
Deprecated. |
static void |
logStarted(TaskAttemptID 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, logFailed, logFinished, logFinished, logStarted, logStarted |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public JobHistory.ReduceAttempt()
Method Detail |
---|
@Deprecated public static void logStarted(String jobid, String taskid, String attemptid, long startTime, String hostName)
public static void logStarted(TaskAttemptID taskAttemptId, long startTime, String hostName)
taskAttemptId
- task attempt idstartTime
- start timehostName
- host name@Deprecated public static void logFinished(String jobid, String taskid, String attemptid, long shuffleFinished, long sortFinished, long finishTime, String hostname)
public static void logFinished(TaskAttemptID taskAttemptId, long shuffleFinished, long sortFinished, long finishTime, String hostName)
taskAttemptId
- task attempt idshuffleFinished
- shuffle finish timesortFinished
- sort finish timefinishTime
- finish time of taskhostName
- host name where task attempt executed@Deprecated public static void logFailed(String jobid, String taskid, String attemptid, long timestamp, String hostname, String error)
public static void logFailed(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error)
taskAttemptId
- task attempt idtimestamp
- time stamp when task failedhostName
- host name of the task attempt.error
- error message of the task.@Deprecated public static void logKilled(String jobid, String taskid, String attemptid, long timestamp, String hostname, String error)
public static void logKilled(TaskAttemptID taskAttemptId, long timestamp, String hostName, String error)
taskAttemptId
- task attempt idtimestamp
- time stamp when task failedhostName
- host name of the task attempt.error
- error message of the task.public 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()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |