ThriftPlansBuilder

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,278 of 1,2780%116 of 1160%86862942942828
lambda$fragmentToThriftIfAbsent$2(PipelineDistributedPlan, CoordinatorContext, DistributedPlanWorker, Multiset, Map, Map, ListMultimap, DistributedPlanWorker)2370%140%88555511
plansToThrift(CoordinatorContext)1770%140%88444411
setParamsForOlapTableSink(List, Map, CoordinatorContext)1060%140%88262611
computeBucketIdToInstanceId(PipelineDistributedPlan, DistributedPlanWorker, Map)890%140%88202011
filterInstancesWhichReceiveDataFromRemote(PipelineDistributedPlan, DistributedPlanWorker, BiConsumer)780%100%66171711
setMultiCastDestinationThriftIfNotSet(PipelineDistributedPlan)760%100%66181811
computeBucketScanSourceParam(BucketScanSource)560%40%33101011
instanceToDestination(AssignedJob)390%n/a119911
computeExchangeSenderNum(PipelineDistributedPlan)370%20%227711
beToThrift(RuntimeFiltersThriftBuilder, Supplier)360%n/a119911
computeDefaultScanSourceParam(DefaultScanSource)350%20%226611
nonMultiCastDestinationToThrift(PipelineDistributedPlan)340%40%338811
computeInstanceNumPerWorker(List)320%40%337711
computeFileScanRangeParams(PipelineDistributedPlan)320%40%337711
instanceToThrift(TPipelineFragmentParams, AssignedJob, int)310%20%229911
setRuntimePredicateIfNeed(Collection)290%60%447711
lambda$topNFilterToThrift$1(List)290%40%337711
groupInstancePerWorker(PipelineDistributedPlan)220%20%225511
instanceToIndex(List)210%20%224411
setScanSourceParam(TPipelineFragmentParams, AssignedJob, TPipelineInstanceParams)210%20%226611
fragmentToThriftIfAbsent(PipelineDistributedPlan, AssignedJob, Map, ListMultimap, Map, Map, Multiset, CoordinatorContext)160%n/a112211
computeDestIdToInstanceId(PipelineDistributedPlan, DistributedPlanWorker, Map)160%20%225511
lambda$computeDestIdToInstanceId$3(Map, Map, AssignedJob, Integer)90%n/a111111
ignoreDataDistribution(TPipelineFragmentParams)50%n/a112211
topNFilterToThrift(List)40%n/a111111
lambda$plansToThrift$0(RuntimeFiltersThriftBuilder, Supplier, DistributedPlanWorker)40%n/a111111
static {...}40%n/a111111
ThriftPlansBuilder()30%n/a111111