commitJob(JobContext) |  | 0% |  | 0% | 2 | 2 | 29 | 29 | 1 | 1 |
innerCommitTask(ExecutorService, TaskAttemptContext) |  | 0% |  | 0% | 2 | 2 | 24 | 24 | 1 | 1 |
loadAndCommit(CommitContext, ExecutorService, FileStatus) |  | 0% |  | 0% | 3 | 3 | 14 | 14 | 1 | 1 |
Committer(Path, JobContext, String) |  | 0% | | n/a | 1 | 1 | 12 | 12 | 1 | 1 |
saveSummaryReportQuietly(String, JobContext, SuccessData, Throwable) |  | 0% |  | 0% | 4 | 4 | 18 | 18 | 1 | 1 |
commitTask(TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 13 | 13 | 1 | 1 |
setupJob(JobContext) |  | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
cleanup(ExecutorService, boolean) |  | 0% |  | 0% | 2 | 2 | 15 | 15 | 1 | 1 |
abortJob(JobContext, JobStatus.State) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
logUncompletedMPUIfPresent(Path) |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
loadAndCommitPendingSets(ExecutorService, CommitContext) |  | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
lambda$abortTask$13(FileStatus) |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
createSuccessData(Iterable) |  | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
cleanupStagingDir() |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
Committer(Path, TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
setupTask(TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
abortTask(TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
lambda$innerCommitTask$11(List, FileStatus) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
recoverTask(TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
checkJobId(JobContext) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
loadAndAbort(ExecutorService, FileStatus) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
loadAndRevert(ExecutorService, FileStatus) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
toString() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
Committer(Path, JobContext) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
loadAndRevertPendingSets(ExecutorService, CommitContext) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
lambda$commitJob$0(List, FileStatus) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
lambda$loadAndCommit$9(CommitContext, Pending) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
cleanupResources() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$cleanup$15(MultipartUpload) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$abortTask$12(FileStatus) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$commitJob$2(ExecutorService, List) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$abortTask$14(Path) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$commitTask$10(Path) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
commitThreads() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$loadAndCommitPendingSets$6(CommitContext, ExecutorService, FileStatus) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$loadAndCommit$8(Pending, Exception) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$loadAndRevertPendingSets$7(ExecutorService, FileStatus) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$loadAndCommitPendingSets$5(ExecutorService, FileStatus) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$loadAndCommitPendingSets$4(ExecutorService, FileStatus) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$commitJob$3(ExecutorService) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$commitJob$1() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getOutputPath() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getWorkPath() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
jobId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
needsTaskCommit(TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |