executeOneTaskAttempt(int, int, int) |  | 0% |  | 0% | 2 | 2 | 26 | 26 | 1 | 1 |
createFilesOrDirs(List, Path, String, ExecutorService, int, int, int, boolean) |  | 0% |  | 0% | 4 | 4 | 16 | 16 | 1 | 1 |
createStageConfig(int, int, int, Path) |  | 0% |  | 0% | 2 | 2 | 25 | 25 | 1 | 1 |
createFilesOrDirs(Path, String, ExecutorService, int, int, int, boolean) |  | 0% |  | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
executeTaskAttempts(int, int) |  | 0% |  | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
setup() |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
asyncMkdirs(Collection) |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
teardown() |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
assertCleanupResult(CleanupJobStage.Result, CleanupJobStage.Outcome, int) |  | 0% |  | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
readText(Path) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
verifyManifestTaskAttemptID(TaskManifest, String) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
enableManifestCommitter(Configuration) |  | 0% |  | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
AbstractManifestCommitterTest() |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
cleanup(boolean, boolean, boolean, boolean, CleanupJobStage.Outcome, int) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
lsR(FileSystem, Path, boolean) |  | 0% |  | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
createTaskStageConfig(int, String, String) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
makeStoreOperationsUnreliable() |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
lambda$asyncPut$3(Path, byte[], CompletableFuture) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
asyncPut(Path, byte[]) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
verifyManifestFilesMatch(TaskManifest, List) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
verifyPath(String, Path, Path) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
asyncMkdir(Path) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
verifyJobDirsCleanedUp() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
lambda$asyncMkdir$2(Path, CompletableFuture) |  | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
lambda$subpaths$1(Path, int) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$createFilesOrDirs$0(boolean, Path, byte[]) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
lambda$executeTaskAttempts$5(List, int, Integer) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
createManifestStoreOperations() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
subpaths(Path, int) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
describe(String, Object[]) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
toMap(List) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
verifySuccessMarker(Path, String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
createStageConfigForJob(int, Path) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
dumpFileSystemIOStatistics() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
pathMustExist(String, Path) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
readFile(Path) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
withManifestDir(Path) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
createContract(Configuration) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
createConfiguration() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$lsR$7(LocatedFileStatus) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getConfiguration() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setStoreOperations(ManifestStoreOperations) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getTotalDataSize() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTestPath() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setSubmitter(CloseableTaskPoolSubmitter) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getExecutorService() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setStageStatistics(IOStatisticsStore) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getReportDirUri() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setJobStageConfig(StageConfig) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setDestDir(Path) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
progressOf(StageConfig) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getStoreOperations() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTaskAttemptIds() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTaskIds() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getManifestDir() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getSubmitter() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getStageStatistics() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getProgressCounter() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getReportDir() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
threadLeakage() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getJobStageConfig() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getDestDir() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTestTimeoutMillis() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getThreadLeakTracker() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$executeOneTaskAttempt$6(TaskManifest) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$toMap$4(TaskManifest) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |