| SqlStageExecution(Session, StageExecutionStateMachine, PlanFragment, RemoteTaskFactory, NodeTaskMap, boolean, Executor, FailureDetector, double, TableWriteInfo) |  | 0% | | 0% | 3 | 3 | 42 | 42 | 1 | 1 |
| updateTaskStatus(TaskId, TaskStatus) | | 0% | | 0% | 10 | 10 | 31 | 31 | 1 | 1 |
| scheduleTask(InternalNode, TaskId, Multimap) | | 0% | | 0% | 4 | 4 | 20 | 20 | 1 | 1 |
| addExchangeLocations(PlanFragmentId, Set, boolean) | | 0% | | 0% | 7 | 7 | 21 | 21 | 1 | 1 |
| scheduleSplits(InternalNode, Multimap, Multimap) | | 0% | | 0% | 5 | 5 | 21 | 21 | 1 | 1 |
| createSqlStageExecution(StageExecutionId, PlanFragment, RemoteTaskFactory, Session, boolean, NodeTaskMap, ExecutorService, FailureDetector, SplitSchedulerStats, TableWriteInfo) | | 0% | | 0% | 2 | 2 | 14 | 14 | 1 | 1 |
| checkAllTaskFinal() | | 0% | | 0% | 5 | 5 | 9 | 9 | 1 | 1 |
| setOutputBuffers(OutputBuffers) | | 0% | | 0% | 5 | 5 | 12 | 12 | 1 | 1 |
| isRecoverable(List) | | 0% | | 0% | 5 | 5 | 6 | 6 | 1 | 1 |
| scheduleTask(InternalNode, int) | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
| rewriteTransportFailure(ExecutionFailureInfo) | | 0% | | 0% | 3 | 3 | 12 | 12 | 1 | 1 |
| schedulingComplete() | | 0% | | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
| createRemoteSplitFor(TaskId, URI, TaskId) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| schedulingComplete(PlanNodeId) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| lambda$scheduleTask$6(ImmutableMultimap.Builder, TaskId, PlanNodeId, RemoteTask) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| requiresMaterializedCTE() | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| registerStageTaskRecoveryCallback(SqlStageExecution.StageTaskRecoveryCallback) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| getRequiredCTEList() | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| removeRemoteSourceIfSingleTaskStage(TaskId) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| recordSchedulerRunningTime(long, long) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| recordSchedulerBlockedTime(ScheduleResult.BlockedReason, long) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| getTotalCpuTime() | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| getRawInputDataSize() | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| getCteIdFromSource(PlanNode) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| getCTEWriterId() | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| static {...} | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| lambda$isCTETableFinishStage$11(PlanNode) | | 0% | | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
| initialize() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| getStageExecutionInfo() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getAllTasks() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| cancel() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| abort() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| getWrittenIntermediateDataSize() | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| getAllTaskInfo() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| isCTETableFinishStage() | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| updateFinalTaskInfo(TaskInfo) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| hasTasks() | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$getWrittenIntermediateDataSize$4(RemoteTask) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$getRequiredCTEList$16(PlanNode) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$getTotalCpuTime$2(RemoteTask) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getBasicStageStats() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$updateTaskStatus$17() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$initialize$1(Set) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$initialize$0(StageExecutionState) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| addStateChangeListener(StateMachine.StateChangeListener) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| addFinalStageInfoListener(StateMachine.StateChangeListener) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| addCompletedDriverGroupsChangedListener(Consumer) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getOutputBuffers() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| beginScheduling() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| transitionToFinishedTaskScheduling() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| transitionToSchedulingSplits() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getScheduledNodes() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| recordGetSplitTime(long) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$null$15() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$requiresMaterializedCTE$13(PlanNode) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getCteIdFromSource$10() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getWrittenIntermediateDataSize$5(RemoteTask) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getRawInputDataSize$3(RemoteTask) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getStageExecutionId() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getState() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getUserMemoryReservation() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getTotalMemoryReservation() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| toString() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getCteIdFromSource$9(PlanNode) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getFragment() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getRequiredCTEList$14(PlanNode) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$requiresMaterializedCTE$12(PlanNode) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getCteIdFromSource$8(PlanNode) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$scheduleTask$7(InternalNode) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |