commitTask(TaskAttemptContext, Path) |  | 0% |  | 0% | 10 | 10 | 30 | 30 | 1 | 1 |
recoverTask(TaskAttemptContext) |  | 0% |  | 0% | 9 | 9 | 31 | 31 | 1 | 1 |
mergePaths(FileSystem, FileStatus, Path, JobContext) |  | 0% |  | 0% | 10 | 10 | 23 | 23 | 1 | 1 |
commitJobInternal(JobContext) |  | 0% |  | 0% | 8 | 8 | 22 | 22 | 1 | 1 |
FileOutputCommitter(Path, JobContext) |  | 0% |  | 0% | 4 | 4 | 16 | 16 | 1 | 1 |
renameOrMerge(FileSystem, FileStatus, Path, JobContext) |  | 0% |  | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
toString() |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
commitJob(JobContext) |  | 0% |  | 0% | 4 | 4 | 14 | 14 | 1 | 1 |
abortTask(TaskAttemptContext, Path) |  | 0% |  | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
setupJob(JobContext) |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
cleanupJob(JobContext) |  | 0% |  | 0% | 3 | 3 | 12 | 12 | 1 | 1 |
FileOutputCommitter(Path, TaskAttemptContext) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
needsTaskCommit(TaskAttemptContext, Path) |  | 0% |  | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
getAllCommittedTaskPaths(JobContext) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getCommittedTaskPath(int, TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getCommittedTaskPath(int, TaskAttemptContext, Path) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getTaskAttemptPath(TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getTaskAttemptPath(TaskAttemptContext, Path) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getJobAttemptPath(int, Path) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPendingTaskAttemptsPath(JobContext, Path) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isCommitJobRepeatable(JobContext) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
reportProgress(JobContext) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
getPendingJobAttemptsPath(Path) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getAppAttemptId(JobContext) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCommittedTaskPath(TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCommittedTaskPath(TaskAttemptContext, Path) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getJobAttemptPath(JobContext) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getJobAttemptPath(JobContext, Path) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getJobAttemptPath(int) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPendingTaskAttemptsPath(JobContext) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
commitTask(TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
abortTask(TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
needsTaskCommit(TaskAttemptContext) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPendingJobAttemptsPath() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
abortJob(JobContext, JobStatus.State) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getOutputPath() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getWorkPath() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isRecoverySupported() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setupTask(TaskAttemptContext) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |