AbstractS3ACommitter

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,536 of 1,5360%64 of 640%1041044034037272
AbstractS3ACommitter(Path, TaskAttemptContext)1170%20%22242411
commitJob(JobContext)1070%40%33333311
maybeSaveSummary(String, CommitContext, SuccessData, Throwable, boolean, boolean)940%80%55272711
loadAndCommit(CommitContext, AbstractS3ACommitter.ActiveCommit, FileStatus)880%40%33212111
createSuccessData(JobContext, List, IOStatisticsSnapshot, Configuration)730%40%33222211
abortPendingUploadsInCleanup(boolean, CommitContext)710%40%33222211
toString()560%n/a119911
buildJobUUID(Configuration, JobID)560%80%55131311
setupTask(TaskAttemptContext)550%40%33121211
setupJob(JobContext)490%20%22121211
commitPendingUploads(CommitContext, AbstractS3ACommitter.ActiveCommit)480%20%22121211
loadAndAbort(CommitContext, AbstractS3ACommitter.ActiveCommit, FileStatus, boolean, boolean)440%n/a11121211
abortPendingUploads(CommitContext, List, boolean)400%40%339911
abortPendingUploads(CommitContext, AbstractS3ACommitter.ActiveCommit, boolean, boolean)400%20%229911
loadAndRevert(CommitContext, AbstractS3ACommitter.ActiveCommit, FileStatus)390%n/a11101011
warnOnActiveUploads(Path)390%40%33151511
maybeCreateSuccessMarkerFromCommits(CommitContext, AbstractS3ACommitter.ActiveCommit)380%20%229911
cleanupJob(JobContext)360%n/a117711
abortJob(JobContext, JobStatus.State)280%n/a115511
precommitCheckPendingFiles(CommitContext, AbstractS3ACommitter.ActiveCommit)260%n/a118811
maybeCreateSuccessMarker(JobContext, List, IOStatisticsSnapshot)210%20%226611
cleanup(CommitContext, boolean)210%n/a115511
recoverTask(TaskAttemptContext)200%n/a114411
initiateJobOperation(JobContext)170%n/a116611
getDestFS()160%20%224411
initOutput(Path)150%n/a114411
initiateTaskOperation(JobContext)150%n/a116611
deleteTaskAttemptPathQuietly(TaskAttemptContext)140%n/a113311
lambda$loadAndAbort$6(CommitContext, boolean, FileSystem, SinglePendingCommit)140%20%226611
maybeIgnore(boolean, String, InvocationRaisingIOE)110%20%224411
lambda$warnOnActiveUploads$11(DateFormat, MultipartUpload)110%n/a113311
commitJobInternal(CommitContext, AbstractS3ACommitter.ActiveCommit)100%n/a113311
maybeIgnore(boolean, String, IOException)100%20%224411
lambda$loadAndCommit$5(CommitContext, AbstractS3ACommitter.ActiveCommit, SinglePendingCommit)100%n/a114411
setWorkPath(Path)80%n/a113311
lambda$abortPendingUploads$10(CommitContext, AbstractS3ACommitter.ActiveCommit, boolean, boolean, FileStatus)80%n/a111111
lambda$commitPendingUploads$0(CommitContext, AbstractS3ACommitter.ActiveCommit, FileStatus)80%n/a111111
setOutputPath(Path)70%n/a112211
getTaskAttemptFilesystem(TaskAttemptContext)70%n/a111111
updateCommonContext()70%n/a112211
startOperation(String, String, String)70%n/a111111
lambda$deleteTaskAttemptPathQuietly$9(TaskAttemptContext, Path)70%n/a112211
lambda$abortPendingUploadsInCleanup$8(CommitContext, MultipartUpload)70%n/a112211
lambda$precommitCheckPendingFiles$3(FileSystem, CommitContext, FileStatus)70%n/a112211
getDestinationFS(Path, Configuration)60%n/a112211
shouldAbortUploadsInCleanup()60%n/a112211
getJobCommitThreadCount(JobContext)60%n/a111111
getTaskCommitThreadCount(JobContext)60%n/a111111
lambda$commitPendingUploads$2(CommitContext, AbstractS3ACommitter.ActiveCommit, FileStatus)60%n/a111111
lambda$commitPendingUploads$1(CommitContext, AbstractS3ACommitter.ActiveCommit, FileStatus)60%n/a111111
getJobAttemptPath(JobContext)50%n/a111111
abortJobInternal(CommitContext, boolean)50%n/a112211
jobCompleted(boolean)50%n/a112211
lambda$commitJobInternal$7(CommitContext, AbstractS3ACommitter.ActiveCommit)50%n/a111111
setConf(Configuration)40%n/a112211
getDestS3AFS()40%n/a111111
setDestFS(FileSystem)40%n/a112211
getTaskAttemptPath(TaskAttemptContext)40%n/a111111
getIOStatistics()40%n/a111111
lambda$loadAndCommit$4(CommitContext, SinglePendingCommit, Exception)40%n/a111111
static {...}40%n/a112211
getJobContext()30%n/a111111
getOutputPath()30%n/a111111
getWorkPath()30%n/a111111
getConf()30%n/a111111
getUUID()30%n/a111111
getUUIDSource()30%n/a111111
getCommitOperations()30%n/a111111
getRole()30%n/a111111
getAuditSpanSource()30%n/a111111
requiresDelayedCommitOutputInFileSystem()20%n/a111111
preCommitJob(CommitContext, AbstractS3ACommitter.ActiveCommit)10%n/a111111