serviceInit(Configuration) |  | 0% |  | 0% | 16 | 16 | 107 | 107 | 1 | 1 |
serviceStart() |  | 0% |  | 0% | 7 | 7 | 43 | 43 | 1 | 1 |
parsePreviousJobHistory() |  | 0% |  | 0% | 8 | 8 | 35 | 35 | 1 | 1 |
main(String[]) |  | 0% |  | 0% | 3 | 3 | 43 | 43 | 1 | 1 |
shutDownJob() |  | 0% |  | 0% | 8 | 8 | 26 | 26 | 1 | 1 |
MRAppMaster(ApplicationAttemptId, ContainerId, String, int, int, Clock, long) |  | 0% | | n/a | 1 | 1 | 21 | 21 | 1 | 1 |
shouldAttemptRecovery() |  | 0% |  | 0% | 9 | 9 | 22 | 22 | 1 | 1 |
cleanupStagingDir() |  | 0% |  | 0% | 3 | 3 | 13 | 13 | 1 | 1 |
readJustAMInfos() |  | 0% |  | 0% | 5 | 5 | 22 | 22 | 1 | 1 |
createJob(Configuration, JobStateInternal, String) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
initJobCredentialsAndUGI(Configuration) |  | 0% |  | 0% | 2 | 2 | 16 | 16 | 1 | 1 |
initAndStartAppMaster(MRAppMaster, JobConf, String) |  | 0% |  | 0% | 3 | 3 | 16 | 16 | 1 | 1 |
sendJobEndNotify(JobEndNotifier) |  | 0% |  | 0% | 2 | 2 | 11 | 11 | 1 | 1 |
callWithJobClassLoader(Configuration, MRAppMaster.ExceptionAction) |  | 0% |  | 0% | 5 | 5 | 13 | 13 | 1 | 1 |
notifyIsLastAMRetry(boolean) |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
processRecovery() |  | 0% |  | 0% | 5 | 5 | 12 | 12 | 1 | 1 |
cleanUpPreviousJobOutput() |  | 0% |  | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
callWithJobClassLoader(Configuration, MRAppMaster.Action) |  | 0% |  | 0% | 5 | 5 | 7 | 7 | 1 | 1 |
isJobNamePatternMatch(JobConf, String) |  | 0% |  | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
isCommitJobRepeatable() |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
isRecoverySupported() |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
getJobContextFromConf(Configuration) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
getPreviousJobHistoryStream(Configuration, ApplicationAttemptId) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
validateInputParam(String, String) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
startJobs() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
exitMRAppMaster(int, Throwable) |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
createTaskAttemptListener(AppContext, AMPreemptionPolicy) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
keepJobFiles(JobConf, String) |  | 0% |  | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
createJobHistoryHandler(AppContext) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
MRAppMaster(ApplicationAttemptId, ContainerId, String, int, int, long) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
createSpeculator(Configuration, AppContext) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
createCommitterEventHandler(AppContext, OutputCommitter) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
cleanupInterruptedCommit(Configuration, FileSystem, Path) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
createOutputCommitter(Configuration) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
createPreemptionPolicy(Configuration) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isFirstAttempt() |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
recovered() |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
createTaskAttemptFinishingMonitor(EventHandler) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
createContainerAllocator(ClientService, AppContext) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
createJobFinishEventHandler() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
createContainerLauncher(AppContext) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
createStagingDirCleaningService() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
createClientService(AppContext) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
createJobClassLoader(Configuration) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
createDispatcher() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getRMHeartbeatHandler() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getAppID() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getStartCount() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isLastAMRetry() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isKeepFailedTaskFiles(JobConf) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getFileSystem(Configuration) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCredentials() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
sysexit() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getAttemptID() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getJobId() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCommitter() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isNewApiCommitter() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getContext() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getDispatcher() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCompletedTaskFromPreviousRun() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getAllAMInfos() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getContainerAllocator() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getContainerLauncher() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTaskAttemptListener() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
stop() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
serviceStop() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getClientService() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |