| testCommitLifecycle() |  | 0% | | n/a | 1 | 1 | 57 | 57 | 1 | 1 |
| testOutputFormatIntegration() | | 0% | | n/a | 1 | 1 | 53 | 53 | 1 | 1 |
| testParallelJobsToAdjacentPaths() | | 0% | | 0% | 3 | 3 | 48 | 48 | 1 | 1 |
| testMapFileOutputCommitter() | | 0% | | n/a | 1 | 1 | 39 | 39 | 1 | 1 |
| testConcurrentCommitTaskWithSubDir() | | 0% | | 0% | 4 | 4 | 28 | 28 | 1 | 1 |
| testTwoTaskAttemptsCommit() | | 0% | | n/a | 1 | 1 | 34 | 34 | 1 | 1 |
| testRecoveryAndCleanup() | | 0% | | n/a | 1 | 1 | 30 | 30 | 1 | 1 |
| validateContent(Path, boolean, String) | | 0% | | 0% | 2 | 2 | 18 | 18 | 1 | 1 |
| testFailAbort() | | 0% | | n/a | 1 | 1 | 23 | 23 | 1 | 1 |
| startJob(TestManifestCommitProtocol.CommitterFactory, boolean) | | 0% | | 0% | 2 | 2 | 14 | 14 | 1 | 1 |
| testCommitterWithDuplicatedCommit() | | 0% | | n/a | 1 | 1 | 18 | 18 | 1 | 1 |
| writeMapFileOutput(RecordWriter, TaskAttemptContext) | | 0% | | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
| testAMWorkflow() | | 0% | | n/a | 1 | 1 | 18 | 18 | 1 | 1 |
| validateMapFileOutputContent(FileSystem, Path) | | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
| TestManifestCommitProtocol() | | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
| writeOutput(RecordWriter, TaskAttemptContext) | | 0% | | n/a | 1 | 1 | 12 | 12 | 1 | 1 |
| lambda$testConcurrentCommitTaskWithSubDir$12(TextOutputFormat[], int, TaskAttemptContext[]) | | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
| loadReport(String, boolean) | | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
| teardown() | | 0% | | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
| setupJob(TestManifestCommitProtocol.JobData) | | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
| assertJobAbortCleanedUp(TestManifestCommitProtocol.JobData) | | 0% | | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
| assertCommitterFactoryIsManifestCommitter(JobContext, Path) | | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
| getReaders(FileSystem, Path, Configuration) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| writeTextOutput(TaskAttemptContext) | | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
| testCommitterWithNoOutputs() | | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
| commitTaskAndJob(ManifestCommitter, JobContext, TaskAttemptContext) | | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
| abortJobQuietly(ManifestCommitter, JobContext, TaskAttemptContext) | | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
| static {...} | | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
| getPart0000(Path) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| testAbortTaskThenJob() | | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
| executeWork(String, TestManifestCommitProtocol.JobData, TestManifestCommitProtocol.ActionToTest) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| assertConfigurationUsesManifestCommitter(Configuration) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| lambda$testCommitLifecycle$2(LocatedFileStatus) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| newJob(Path, Configuration, String) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| setupCommitter(ManifestCommitter, TaskAttemptContext) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| lambda$testAbortJobNotTask$11(Job, JobContext, TaskAttemptContext, ManifestCommitter) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| assertPart0000DoesNotExist(Path) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$testCommitJobButNotTask$8(Job, JobContext, TaskAttemptContext, ManifestCommitter) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| lambda$static$5(Path) | | 0% | | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
| assertTaskAttemptPathDoesNotExist(ManifestCommitter, TaskAttemptContext) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| assertJobAttemptPathDoesNotExist(ManifestCommitter, JobContext) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| cleanupOutputDir() | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| setup() | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| assertJobAttemptPathExists(ManifestCommitter, JobContext) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| lambda$testUnsupportedSchema$13() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| newJob() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| abortJobQuietly(TestManifestCommitProtocol.JobData) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| assertSuccessMarkerDoesNotExist(Path) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| createConfiguration() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| executeWork(String, TestManifestCommitProtocol.ActionToTest) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| expectJobCommitFailure(JobContext, ManifestCommitter, Class) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| expectFNFEonTaskCommit(ManifestCommitter, TaskAttemptContext) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getMethodName() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| logAggregateIOStatistics() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| abortInTeardown(TestManifestCommitProtocol.JobData) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| createCommitter(TaskAttemptContext) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| createCommitter(Path, TaskAttemptContext) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| startJob(boolean) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| expectJobCommitToFail(JobContext, ManifestCommitter) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| testCommitJobButNotTask() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| testAbortJobNotTask() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$expectFNFEonTaskCommit$4(ManifestCommitter, TaskAttemptContext) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$expectJobCommitFailure$3(ManifestCommitter, JobContext) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| bindCommitter(Configuration) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| loadManifest(Path) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| testAbortTaskNoWorkDone() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| testAbortJobNoWorkDone() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| testUnsupportedSchema() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| unsetUUIDOptions(Configuration) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$testAbortTaskThenJob$9(ManifestCommitter) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$testAbortJobNoWorkDone$7(Job, JobContext, TaskAttemptContext, ManifestCommitter) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getPart0000$1(Path) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| commitTask(ManifestCommitter, TaskAttemptContext) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| commitJob(ManifestCommitter, JobContext) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$assertPart0000DoesNotExist$10(Path) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$testAbortTaskNoWorkDone$6(Job, JobContext, TaskAttemptContext, ManifestCommitter) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$testRecoveryAndCleanup$0(ManifestCommitter, TaskAttemptContext) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getOutputDir() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getJobId() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getAttempt0() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getTaskAttempt0() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getAttempt1() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getTaskAttempt1() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| suitename() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| log() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| shouldExpectSuccessMarker() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| validateTaskAttemptPathDuringWrite(Path, long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| validateTaskAttemptPathAfterWrite(Path, long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| validateTaskAttemptWorkingDirectory(ManifestCommitter, TaskAttemptContext) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |