getTaskSources(Iterator, PlanFragment, Session, PrestoSparkNativeTaskInputs) |  | 0% |  | 0% | 6 | 6 | 51 | 51 | 1 | 1 |
doCreate(int, int, SerializedPrestoSparkTaskDescriptor, Iterator, PrestoSparkTaskInputs, CollectionAccumulator, CollectionAccumulator, Class) |  | 0% |  | 0% | 3 | 3 | 37 | 37 | 1 | 1 |
PrestoSparkNativeTaskExecutorFactory(SessionPropertyManager, BlockEncodingManager, JsonCodec, JsonCodec, Codec, Codec, PrestoSparkExecutionExceptionFactory, Set, PrestoSparkBroadcastTableCacheManager, NativeExecutionProcessFactory, NativeExecutionTaskFactory, PrestoSparkShuffleInfoTranslator) |  | 0% | | n/a | 1 | 1 | 13 | 13 | 1 | 1 |
processFailure(RuntimeException, NativeExecutionProcess, boolean, Duration) |  | 0% |  | 0% | 5 | 5 | 13 | 13 | 1 | 1 |
processTaskInfoForErrorsOrCompletion(TaskInfo) |  | 0% |  | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
lambda$getTaskSources$13(AtomicLong, RemoteSourceNode, BroadcastFileInfo) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
completeTask(boolean, CollectionAccumulator, NativeExecutionTask, Codec, PrestoSparkNativeTaskExecutorFactory.CpuTracker) |  | 0% |  | 0% | 2 | 2 | 11 | 11 | 1 | 1 |
createAndStartNativeExecutionProcess(Session) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
create(int, int, SerializedPrestoSparkTaskDescriptor, Iterator, PrestoSparkTaskInputs, CollectionAccumulator, CollectionAccumulator, Class) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getBroadcastDirectoryPath(Session) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isCommunicationLoss(RuntimeException) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
tryGetTaskInfo(NativeExecutionTask) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
findTableWriteNode(PlanNode) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$getTaskSources$5(List, PlanNodeId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$completeTask$2(Optional, long) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$getTaskSources$11(Page) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$null$10(Page, int) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getTaskSources$4(Set, PlanNodeId) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
close() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$getTaskSources$7(AtomicLong, long) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$processTaskInfoForErrorsOrCompletion$3() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$doCreate$1(Session, PrestoSparkShuffleWriteDescriptor) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$doCreate$0(ImmutableMap.Builder, PrestoSparkAuthenticatorProvider) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getTaskSources$12(String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getTaskSources$9(SerializedPage) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getTaskSources$6(TaskSource) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getTaskSources$8(PrestoSparkSerializedPage) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |