| AbstractS3ACommitter(Path, TaskAttemptContext) |  | 0% | | 0% | 2 | 2 | 24 | 24 | 1 | 1 |
| commitJob(JobContext) | | 0% | | 0% | 3 | 3 | 33 | 33 | 1 | 1 |
| maybeSaveSummary(String, CommitContext, SuccessData, Throwable, boolean, boolean) | | 0% | | 0% | 5 | 5 | 27 | 27 | 1 | 1 |
| loadAndCommit(CommitContext, AbstractS3ACommitter.ActiveCommit, FileStatus) | | 0% | | 0% | 3 | 3 | 21 | 21 | 1 | 1 |
| createSuccessData(JobContext, List, IOStatisticsSnapshot, Configuration) | | 0% | | 0% | 3 | 3 | 22 | 22 | 1 | 1 |
| abortPendingUploadsInCleanup(boolean, CommitContext) | | 0% | | 0% | 3 | 3 | 22 | 22 | 1 | 1 |
| setupTask(TaskAttemptContext) | | 0% | | 0% | 3 | 3 | 12 | 12 | 1 | 1 |
| toString() | | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
| buildJobUUID(Configuration, JobID) | | 0% | | 0% | 5 | 5 | 13 | 13 | 1 | 1 |
| setupJob(JobContext) | | 0% | | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
| commitPendingUploads(CommitContext, AbstractS3ACommitter.ActiveCommit) | | 0% | | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
| loadAndAbort(CommitContext, AbstractS3ACommitter.ActiveCommit, FileStatus, boolean, boolean) | | 0% | | n/a | 1 | 1 | 12 | 12 | 1 | 1 |
| abortPendingUploads(CommitContext, List, boolean) | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
| abortPendingUploads(CommitContext, AbstractS3ACommitter.ActiveCommit, boolean, boolean) | | 0% | | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
| loadAndRevert(CommitContext, AbstractS3ACommitter.ActiveCommit, FileStatus) | | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
| warnOnActiveUploads(Path) | | 0% | | 0% | 3 | 3 | 15 | 15 | 1 | 1 |
| maybeCreateSuccessMarkerFromCommits(CommitContext, AbstractS3ACommitter.ActiveCommit) | | 0% | | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
| cleanupJob(JobContext) | | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
| abortJob(JobContext, JobStatus.State) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| precommitCheckPendingFiles(CommitContext, AbstractS3ACommitter.ActiveCommit) | | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
| maybeCreateSuccessMarker(JobContext, List, IOStatisticsSnapshot) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| cleanup(CommitContext, boolean) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| recoverTask(TaskAttemptContext) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| initiateJobOperation(JobContext) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| getDestFS() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| initOutput(Path) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| initiateTaskOperation(JobContext) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| deleteTaskAttemptPathQuietly(TaskAttemptContext) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$loadAndAbort$6(CommitContext, boolean, FileSystem, SinglePendingCommit) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| maybeIgnore(boolean, String, InvocationRaisingIOE) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| lambda$warnOnActiveUploads$11(DateFormat, MultipartUpload) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| commitJobInternal(CommitContext, AbstractS3ACommitter.ActiveCommit) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| maybeIgnore(boolean, String, IOException) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| lambda$loadAndCommit$5(CommitContext, AbstractS3ACommitter.ActiveCommit, SinglePendingCommit) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| setWorkPath(Path) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$abortPendingUploads$10(CommitContext, AbstractS3ACommitter.ActiveCommit, boolean, boolean, FileStatus) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$commitPendingUploads$0(CommitContext, AbstractS3ACommitter.ActiveCommit, FileStatus) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| setOutputPath(Path) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getTaskAttemptFilesystem(TaskAttemptContext) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| updateCommonContext() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| startOperation(String, String, String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$deleteTaskAttemptPathQuietly$9(TaskAttemptContext, Path) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$abortPendingUploadsInCleanup$8(CommitContext, MultipartUpload) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$precommitCheckPendingFiles$3(FileSystem, CommitContext, FileStatus) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getDestinationFS(Path, Configuration) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| shouldAbortUploadsInCleanup() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getJobCommitThreadCount(JobContext) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getTaskCommitThreadCount(JobContext) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$commitPendingUploads$2(CommitContext, AbstractS3ACommitter.ActiveCommit, FileStatus) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$commitPendingUploads$1(CommitContext, AbstractS3ACommitter.ActiveCommit, FileStatus) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getJobAttemptPath(JobContext) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| abortJobInternal(CommitContext, boolean) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| jobCompleted(boolean) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$commitJobInternal$7(CommitContext, AbstractS3ACommitter.ActiveCommit) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| setConf(Configuration) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getDestS3AFS() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| setDestFS(FileSystem) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getTaskAttemptPath(TaskAttemptContext) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getIOStatistics() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$loadAndCommit$4(CommitContext, SinglePendingCommit, Exception) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| static {...} | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getJobContext() | | 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 |
| getConf() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getUUID() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getUUIDSource() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getCommitOperations() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getRole() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getAuditSpanSource() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| requiresDelayedCommitOutputInFileSystem() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| preCommitJob(CommitContext, AbstractS3ACommitter.ActiveCommit) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |