BaseDataPublisher(State) | | 0% | | 0% | 6 | 6 | 47 | 47 | 1 | 1 |
mergeMetadataAndCollectPartitionNames(Collection, Set) | | 0% | | 0% | 10 | 10 | 36 | 36 | 1 | 1 |
publishData(WorkUnitState, int, boolean, Set) | | 0% | | 0% | 6 | 6 | 24 | 24 | 1 | 1 |
addSingleTaskWriterOutputToExistingDir(Path, Path, WorkUnitState, int, ParallelRunner) | | 0% | | 0% | 4 | 4 | 19 | 19 | 1 | 1 |
buildMetadataMergerForBranch(String, int, Path) | | 0% | | 0% | 4 | 4 | 23 | 23 | 1 | 1 |
publishMetadata(Collection) | | 0% | | 0% | 7 | 7 | 18 | 18 | 1 | 1 |
publishMetadata(String, int, Path) | | 0% | | 0% | 5 | 5 | 18 | 18 | 1 | 1 |
addWriterOutputToExistingDir(Path, Path, WorkUnitState, int, ParallelRunner) | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
addLineageInfo(WorkUnitState, int) | | 0% | | 0% | 4 | 4 | 13 | 13 | 1 | 1 |
movePath(ParallelRunner, State, Path, Path, int) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
loadExistingMetadata(Path, int) | | 0% | | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
createDestinationDescriptor(WorkUnitState, int) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
publishData(Collection) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
static {...} | | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
getParallelRunner(FileSystem) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
close() | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
getMetadataOutputPathFromState(WorkUnitState, int) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
getMergedMetadataForPartitionAndBranch(String, int) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
getUserSpecifiedOutputPathFromState(WorkUnitState, int) | | 0% | | 0% | 4 | 4 | 7 | 7 | 1 | 1 |
addWriterOutputToNewDir(Path, Path, WorkUnitState, int, ParallelRunner) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
getMetadataOutputFileForBranch(WorkUnitState, int) | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
publishData(WorkUnitState) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
recordPublisherOutputDirs(Path, Path, int) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
publishSingleTaskData(WorkUnitState, int) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
shouldPublishWriterMetadataForBranch(int) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
publishMultiTaskData(WorkUnitState, int, Set) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getMetadataFileNameForBranch(WorkUnitState, int) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$mergeMetadataAndCollectPartitionNames$1(String, int, WorkUnitState, PartitionIdentifier) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getIntermediateMetadataFromState(WorkUnitState, int) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getPublisherOutputDir(WorkUnitState, int) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
publishMetadata(WorkUnitState) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getMetadataFromWorkUnitState(WorkUnitState) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$mergeMetadataAndCollectPartitionNames$0(PartitionIdentifier) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
shouldPublishMetadataFirst() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
initialize() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |