createStageScheduler(SplitSourceFactory, Session, StreamingSubPlan, Function, Optional, StageId, SqlStageExecution, PartitioningHandle, TableWriteInfo, Set, CTEMaterializationTracker) |  | 0% |  | 0% | 18 | 18 | 68 | 68 | 1 | 1 |
createStreamingLinkedStageExecutions(Session, ExchangeLocationsConsumer, StreamingSubPlan, Function, TableWriteInfo, Optional, boolean, RemoteTaskFactory, SplitSourceFactory, int, CTEMaterializationTracker) |  | 0% |  | 0% | 2 | 2 | 22 | 22 | 1 | 1 |
getBucketToPartition(PartitioningHandle, Function, PlanNode, List) |  | 0% |  | 0% | 6 | 6 | 11 | 11 | 1 | 1 |
SectionExecutionFactory(Metadata, NodePartitioningManager, NodeTaskMap, ExecutorService, ScheduledExecutorService, FailureDetector, SplitSchedulerStats, NodeScheduler, int, boolean) |  | 0% | | n/a | 1 | 1 | 12 | 12 | 1 | 1 |
createSectionExecutions(Session, StreamingPlanSection, ExchangeLocationsConsumer, Optional, OutputBuffers, boolean, RemoteTaskFactory, SplitSourceFactory, int, CTEMaterializationTracker) |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
whenAllStages(Collection, Predicate) |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
lambda$createStageScheduler$7(StageId, Optional, FixedSourcePartitionedScheduler, TaskId) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
getNodePoolSelectionPredicate(StreamingSubPlan) |  | 0% |  | 0% | 4 | 4 | 4 | 4 | 1 | 1 |
SectionExecutionFactory(Metadata, NodePartitioningManager, NodeTaskMap, ExecutorService, ScheduledExecutorService, FailureDetector, SplitSchedulerStats, NodeScheduler, QueryManagerConfig) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
lambda$whenAllStages$11(Predicate, Set, SqlStageExecution, SettableFuture, StageExecutionState) |  | 0% |  | 0% | 4 | 4 | 3 | 3 | 1 | 1 |
lambda$createStageScheduler$3(Set) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
lambda$createStageScheduler$4(SqlStageExecution) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$createSectionExecutions$1(Map, Session, Optional, PartitioningHandle) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getBucketToPartition$10(RemoteSourceNode) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$createStageScheduler$6(RemoteSourceNode) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$createStreamingLinkedStageExecutions$2(Set, StageExecutionState) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
lambda$null$0(Session, Optional, PartitioningHandle) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getNodePoolSelectionPredicate$8(NodePoolType, Node) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getBucketToPartition$9(PlanNode) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$createStageScheduler$5(Split) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |