DistributePlanner

A different version of class was executed at runtime.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total720 of 7200%78 of 780%55551591591616
buildDistributePlans(Map, ListMultimap)1000%100%66212111
plan()880%60%44232311
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
filterInstancesWhichCanReceiveDataFromRemote(PipelineDistributedPlan, boolean, ExchangeNode)300%60%447711
lambda$plan$1(PlanFragmentId, DistributedPlan)260%20%227711
getFirstInstancePerWorker(List)230%20%225511
DistributePlanner(StatementContext, List, boolean, boolean)190%n/a116611
isEnableLocalShufflePlanner()140%40%332211
updateProfileIfPresent(Consumer)110%n/a115511
lambda$plan$0(SummaryProfile)40%n/a111111
static {...}40%n/a111111