DistributePlanner

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total651 of 72410%71 of 788%48551411591216
buildDistributePlans(Map, ListMultimap)1000%100%66212111
plan()950%60%44242411
linkPlans(FragmentIdMapping)850%80%55171711
sortDestinationInstancesByBuckets(PipelineDistributedPlan, List, int)850%100%66161611
sortDestinationInstancesByJoinBuckets(PipelineDistributedPlan, int)840%100%66161611
linkPipelinePlan(PipelineDistributedPlan, PipelineDistributedPlan, ExchangeNode, boolean)610%80%55151511
getDestinationsByBuckets(PipelineDistributedPlan, List, ExchangeNode)450%80%559911
addExternalBackends(BackendDistributedPlanWorkerManager)410%40%339911
lambda$plan$1(PlanFragmentId, DistributedPlan)260%20%227711
isEnableLocalShufflePlanner()140%40%332211
updateProfileIfPresent(Consumer)110%n/a115511
lambda$plan$0(SummaryProfile)40%n/a111111
filterInstancesWhichCanReceiveDataFromRemote(PipelineDistributedPlan, boolean, ExchangeNode)24100%1583%140501
getFirstInstancePerWorker(List)23100%2100%020501
DistributePlanner(StatementContext, List, boolean, boolean, boolean)22100%n/a010701
static {...}4100%n/a010101