| schedule() |  | 0% | | 0% | 34 | 34 | 109 | 109 | 1 | 1 |
| SqlQueryScheduler(LocationFactory, ExecutionPolicy, ExecutorService, SplitSchedulerStats, SectionExecutionFactory, RemoteTaskFactory, SplitSourceFactory, Session, FunctionAndTypeManager, QueryStateMachine, SubPlan, boolean, OutputBuffers, List, WarningCollector, PlanNodeIdAllocator, VariableAllocator, PlanChecker, Metadata, SqlParser, PartialResultQueryManager) | | 0% | | n/a | 1 | 1 | 35 | 35 | 1 | 1 |
| updateStageExecutions(StreamingPlanSection, Map) | | 0% | | 0% | 2 | 2 | 21 | 21 | 1 | 1 |
| performRuntimeOptimizations(StreamingSubPlan) | | 0% | | 0% | 3 | 3 | 17 | 17 | 1 | 1 |
| tryCostBasedOptimize(StreamingPlanSection) | | 0% | | 0% | 4 | 4 | 15 | 15 | 1 | 1 |
| createStageExecutions(SectionExecutionFactory, ExchangeLocationsConsumer, StreamingPlanSection, Optional, OutputBuffers, RemoteTaskFactory, SplitSourceFactory, Session) | | 0% | | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
| initialize() | | 0% | | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
| lambda$addStateChangeListeners$22(SqlStageExecution, StageExecutionState) | | 0% | | 0% | 7 | 7 | 12 | 12 | 1 | 1 |
| lambda$initialize$4(SqlStageExecution, StageExecutionState) | | 0% | | 0% | 7 | 7 | 12 | 12 | 1 | 1 |
| buildStageInfo(SubPlan, Map) | | 0% | | 0% | 2 | 2 | 11 | 11 | 1 | 1 |
| rewritePlan(SubPlan, Map) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| rewriteStreamingSubPlan(StreamingSubPlan, Map) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| isReadyForExecution(StreamingPlanSection) | | 0% | | 0% | 5 | 5 | 10 | 10 | 1 | 1 |
| getSectionsReadyForExecution() | | 0% | | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
| getBufferLocation(RemoteTask, OutputBuffers.OutputBufferId) | | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
| addStateChangeListeners(SectionExecution) | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
| cancelStage(StageId) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| createSqlQueryScheduler(LocationFactory, ExecutionPolicy, ExecutorService, SplitSchedulerStats, SectionExecutionFactory, RemoteTaskFactory, SplitSourceFactory, Session, FunctionAndTypeManager, QueryStateMachine, SubPlan, OutputBuffers, boolean, List, WarningCollector, PlanNodeIdAllocator, VariableAllocator, PlanChecker, Metadata, SqlParser, PartialResultQueryManager) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$tryCostBasedOptimize$15(Map, StreamingSubPlan) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| abort() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$initialize$3(SqlStageExecution, StageExecutionState) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| getStageInfo() | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| startScheduling() | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| lambda$addStateChangeListeners$21(StageExecutionState) | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
| lambda$initialize$2(StageExecutionState) | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
| getTotalCpuTime() | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| updateQueryOutputLocations(QueryStateMachine, OutputBuffers.OutputBufferId, Set, boolean) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| getBasicStageStats() | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| lambda$getStageExecutions$25(ImmutableList) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| getStageExecutions(List) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| getOutputPositions() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getOutputDataSizeInBytes() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$initialize$6(QueryState) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| lambda$new$1(StageExecutionAndScheduler) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getStageExecutions$24(StreamingPlanSection) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getSectionsReadyForExecution$14(StageExecutionState) | | 0% | | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
| start() | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| getStageExecution(PlanFragmentId) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getStageId(PlanFragmentId) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$cancelStage$34(StageId) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$tryCostBasedOptimize$16(PlanFragment, PlanFragment) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| updatePlan(Map) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| isRootFragment(PlanFragment) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| getStageExecutionInfo(PlanFragmentId) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getUserMemoryReservation() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| getTotalMemoryReservation() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| getRawInputDataSizeInBytes() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| getWrittenIntermediateDataSizeInBytes() | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$addStateChangeListeners$23(StageExecutionInfo) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getSectionsReadyForExecution$13(StreamingPlanSection) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$initialize$5(StageExecutionInfo) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$updateStageExecutions$17(OutputBuffers.OutputBufferId, PlanFragmentId, Set, boolean) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$schedule$12(SqlStageExecution, ScheduleResult.BlockedReason, long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$schedule$10(ImmutableList) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| static {...} | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$schedule$9(List) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$new$0(QueryStateMachine, OutputBuffers.OutputBufferId, PlanFragmentId, Set, boolean) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$buildStageInfo$33(Map, SubPlan) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getTotalCpuTime$28(StageExecutionAndScheduler) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$updatePlan$20(Map, SubPlan) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$updateStageExecutions$19(StageExecutionAndScheduler) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$abort$35(StageExecutionAndScheduler) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getStageInfo$32(SqlStageExecution) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getBasicStageStats$31(StageExecutionAndScheduler) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getWrittenIntermediateDataSizeInBytes$30(StageExecutionAndScheduler) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getRawInputDataSizeInBytes$29(StageExecutionAndScheduler) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getTotalMemoryReservation$27(StageExecutionAndScheduler) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$getUserMemoryReservation$26(StageExecutionAndScheduler) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$schedule$11(ExecutionSchedule) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$updateQueryOutputLocations$7(OutputBuffers.OutputBufferId, RemoteTask) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$updateStageExecutions$18(PlanFragmentId, Set, boolean) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$createStageExecutions$8(PlanFragmentId, Set, boolean) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |