Removed Methods |
String getLocalJobFilePath(String )
|
|
void logFailed(String, long, int, int)
|
|
void logFinished(String, long, int, int, int, int, Counters)
|
|
void logStarted(String, long, int, int)
|
|
void logSubmitted(String, JobConf, String, long)
|
|
Added Methods |
String getJobHistoryFileName(JobConf, JobID)
|
Recover the job history filename from the history folder. |
Path getJobHistoryLogLocation(String )
|
Get the job history file path given the history filename |
Path getJobHistoryLogLocationForUser(String, JobConf)
|
Get the user job history file path |
String getUserName(JobConf )
|
Get the user name from the job conf |
void logInited(JobID, long, int, int)
|
Logs launch time of job. |
void logJobInfo(JobID, long, long, int)
|
Log job's submit-time/launch-time
|
void logJobPriority(JobID, JobPriority)
|
Log job's priority. |
void logKilled(JobID, long, int, int)
|
Logs job killed event. |
void logStarted(JobID )
|
Logs job as running
|
Path recoverJobHistoryFile(JobConf, Path)
|
Selects one of the two files generated as a part of recovery. |