SectionExecutionFactory

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total863 of 8630%70 of 700%55551591592020
createStageScheduler(SplitSourceFactory, Session, StreamingSubPlan, Function, Optional, StageId, SqlStageExecution, PartitioningHandle, TableWriteInfo, Set, CTEMaterializationTracker)3620%340%1818686811
createStreamingLinkedStageExecutions(Session, ExchangeLocationsConsumer, StreamingSubPlan, Function, TableWriteInfo, Optional, boolean, RemoteTaskFactory, SplitSourceFactory, int, CTEMaterializationTracker)1370%20%22222211
getBucketToPartition(PartitioningHandle, Function, PlanNode, List)580%100%66111111
SectionExecutionFactory(Metadata, NodePartitioningManager, NodeTaskMap, ExecutorService, ScheduledExecutorService, FailureDetector, SplitSchedulerStats, NodeScheduler, int, boolean)570%n/a11121211
createSectionExecutions(Session, StreamingPlanSection, ExchangeLocationsConsumer, Optional, OutputBuffers, boolean, RemoteTaskFactory, SplitSourceFactory, int, CTEMaterializationTracker)510%n/a119911
whenAllStages(Collection, Predicate)390%40%339911
lambda$createStageScheduler$7(StageId, Optional, FixedSourcePartitionedScheduler, TaskId)320%20%226611
getNodePoolSelectionPredicate(StreamingSubPlan)220%60%444411
SectionExecutionFactory(Metadata, NodePartitioningManager, NodeTaskMap, ExecutorService, ScheduledExecutorService, FailureDetector, SplitSchedulerStats, NodeScheduler, QueryManagerConfig)180%n/a114411
lambda$whenAllStages$11(Predicate, Set, SqlStageExecution, SettableFuture, StageExecutionState)170%60%443311
lambda$createStageScheduler$3(Set)120%n/a115511
lambda$createStageScheduler$4(SqlStageExecution)90%n/a113311
lambda$createSectionExecutions$1(Map, Session, Optional, PartitioningHandle)90%n/a111111
lambda$getBucketToPartition$10(RemoteSourceNode)80%20%221111
lambda$createStageScheduler$6(RemoteSourceNode)80%20%221111
lambda$createStreamingLinkedStageExecutions$2(Set, StageExecutionState)70%20%223311
lambda$null$0(Session, Optional, PartitioningHandle)70%n/a111111
lambda$getNodePoolSelectionPredicate$8(NodePoolType, Node)50%n/a111111
lambda$getBucketToPartition$9(PlanNode)0%n/a111111
lambda$createStageScheduler$5(Split)0%n/a111111