DistributePlanner

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total115 of 72784%18 of 7876%175621158117
sortDestinationInstancesByBuckets(PipelineDistributedPlan, List, int)295665%2880%2651601
sortDestinationInstancesByJoinBuckets(PipelineDistributedPlan, int)295565%2880%2651601
plan(boolean)276971%5116%3462401
linkPlans(FragmentIdMapping, boolean)215873%1787%1541501
plan()80%n/a111111
isEnableLocalShufflePlanner()11392%2250%230201
buildDistributePlans(Map, ListMultimap)100100%1990%1602101
linkPipelinePlan(PipelineDistributedPlan, PipelineDistributedPlan, ExchangeNode, boolean)61100%1787%1501501
getDestinationsByBuckets(PipelineDistributedPlan, List, ExchangeNode)45100%3562%350901
addExternalBackends(BackendDistributedPlanWorkerManager)41100%4100%030901
lambda$plan$1(PlanFragmentId, DistributedPlan)26100%1150%120701
filterInstancesWhichCanReceiveDataFromRemote(PipelineDistributedPlan, boolean, ExchangeNode)24100%6100%040501
getFirstInstancePerWorker(List)23100%2100%020501
DistributePlanner(StatementContext, List, boolean, boolean, boolean)22100%n/a010701
updateProfileIfPresent(Consumer)11100%n/a010501
lambda$plan$0(SummaryProfile)4100%n/a010101
static {...}4100%n/a010101