|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.mapred.JobHistory.JobInfo
public static class JobHistory.JobInfo
Helper class for logging or reading back events related to job start, finish or failure.
Constructor Summary | |
---|---|
JobHistory.JobInfo(String jobId)
Create new JobInfo |
Method Summary | |
---|---|
static String |
decodeJobHistoryFileName(String logFileName)
Helper function to decode the URL of the filename of the job-history log file. |
static String |
encodeJobHistoryFileName(String logFileName)
Helper function to encode the URL of the filename of the job-history log file. |
static String |
encodeJobHistoryFilePath(String logFile)
Helper function to encode the URL of the path of the job-history log file. |
String |
get(JobHistory.Keys k)
Get 'String' value for given key. |
Map<String,JobHistory.Task> |
getAllTasks()
Returns all map and reduce tasks |
int |
getInt(JobHistory.Keys k)
Convert value from history to int and return. |
static String |
getLocalJobFilePath(JobID jobId)
Get the path of the locally stored job file |
static String |
getLocalJobFilePath(String jobid)
Deprecated. |
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(JobID jobid,
long timestamp,
int finishedMaps,
int finishedReduces)
Logs job failed event. |
static void |
logFailed(String jobid,
long timestamp,
int finishedMaps,
int finishedReduces)
Deprecated. |
static void |
logFinished(JobID jobId,
long finishTime,
int finishedMaps,
int finishedReduces,
int failedMaps,
int failedReduces,
Counters counters)
Log job finished. |
static void |
logFinished(String jobId,
long finishTime,
int finishedMaps,
int finishedReduces,
int failedMaps,
int failedReduces,
Counters counters)
Deprecated. |
static void |
logStarted(JobID jobId,
long startTime,
int totalMaps,
int totalReduces)
Logs launch time of job. |
static void |
logStarted(String jobid,
long startTime,
int totalMaps,
int totalReduces)
Deprecated. |
static void |
logSubmitted(JobID jobId,
JobConf jobConf,
String jobConfPath,
long submitTime)
Log job submitted event to history. |
static void |
logSubmitted(String jobid,
JobConf jobConf,
String jobConfPath,
long submitTime)
Deprecated. |
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 java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public JobHistory.JobInfo(String jobId)
Method Detail |
---|
public Map<String,JobHistory.Task> getAllTasks()
@Deprecated public static String getLocalJobFilePath(String jobid)
public static String getLocalJobFilePath(JobID jobId)
jobId
- id of the job
public static String encodeJobHistoryFilePath(String logFile) throws IOException
logFile
- path of the job-history file
IOException
public static String encodeJobHistoryFileName(String logFileName) throws IOException
logFileName
- file name of the job-history file
IOException
public static String decodeJobHistoryFileName(String logFileName) throws IOException
logFileName
- file name of the job-history file
IOException
@Deprecated public static void logSubmitted(String jobid, JobConf jobConf, String jobConfPath, long submitTime) throws IOException
IOException
public static void logSubmitted(JobID jobId, JobConf jobConf, String jobConfPath, long submitTime) throws IOException
jobId
- job id assigned by job tracker.jobConf
- job conf of the jobjobConfPath
- path to job conf xml file in HDFS.submitTime
- time when job tracker received the job
IOException
@Deprecated public static void logStarted(String jobid, long startTime, int totalMaps, int totalReduces)
public static void logStarted(JobID jobId, long startTime, int totalMaps, int totalReduces)
jobId
- job id, assigned by jobtracker.startTime
- start time of job.totalMaps
- total maps assigned by jobtracker.totalReduces
- total reduces.@Deprecated public static void logFinished(String jobId, long finishTime, int finishedMaps, int finishedReduces, int failedMaps, int failedReduces, Counters counters)
public static void logFinished(JobID jobId, long finishTime, int finishedMaps, int finishedReduces, int failedMaps, int failedReduces, Counters counters)
jobId
- job id, assigned by jobtracker.finishTime
- finish time of job in ms.finishedMaps
- no of maps successfully finished.finishedReduces
- no of reduces finished sucessfully.failedMaps
- no of failed map tasks.failedReduces
- no of failed reduce tasks.counters
- the counters from the job@Deprecated public static void logFailed(String jobid, long timestamp, int finishedMaps, int finishedReduces)
public static void logFailed(JobID jobid, long timestamp, int finishedMaps, int finishedReduces)
jobid
- job idtimestamp
- time when job failure was detected in ms.finishedMaps
- no finished map tasks.finishedReduces
- no of finished reduce tasks.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 |