AbstractPrestoSparkQueryExecution

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total2,104 of 2,1040%148 of 1480%1131134224223939
execute()3340%420%2222727211
AbstractPrestoSparkQueryExecution(JavaSparkContext, Session, QueryMonitor, CollectionAccumulator, CollectionAccumulator, PrestoSparkTaskExecutorFactory, PrestoSparkTaskExecutorFactoryProvider, QueryStateTimer, WarningCollector, String, PrestoSparkQueryPlanner.PlanAndMore, Optional, Codec, JsonCodec, JsonCodec, JsonCodec, PrestoSparkRddFactory, TransactionManager, PagesSerde, PrestoSparkExecutionExceptionFactory, Duration, long, PrestoSparkMetadataStorage, Optional, Optional, TempStorage, NodeMemoryConfig, FeaturesConfig, QueryManagerConfig, Set, Optional, PrestoSparkPlanFragmenter, Metadata, PartitioningProviderManager, HistoryBasedPlanStatisticsTracker, Optional)2260%n/a11404011
collectPages(TableWriteInfo, PlanFragment, Map)2180%40%33424211
logShuffleStatsSummary(AbstractPrestoSparkQueryExecution.ShuffleStatsKey, List)1490%80%55373711
createRddForSubPlan(SubPlan, TableWriteInfo, Optional)1390%80%55252511
queryCompletedEvent(Optional, OptionalLong)1180%60%44252511
createRdd(SubPlan, Class, TableWriteInfo)1170%60%44222211
createBroadcastDependency(RddAndMore)950%60%44181811
processBootstrapStats()950%80%55181811
checkPageSinkCommitIsSupported(Session, ExecutionWriterTarget)820%120%77141411
createPartitioner(PartitioningScheme)630%100%66131311
processShuffleStats()620%40%33121211
executeFragment(SubPlan, TableWriteInfo, Optional)510%60%449911
configureOutputPartitioning(Session, SubPlan, int)420%40%33101011
getBucketToPartition(Session, PartitioningHandle, int)370%60%448811
partitionBy(int, JavaPairRDD, PartitioningScheme)290%n/a118811
getTableWriteInfo(Session, SubPlan)250%20%226611
validateStorageCapabilities(TempStorage)210%40%335511
setFinalFragmentedPlan(SubPlan)210%20%224411
getTableWriteInfo(Session, PlanNode)190%20%224411
tuneMaxExecutorsCount()180%20%224411
getPartitionCount(Session, PartitioningHandle)160%n/a115511
getOutputTypes()150%n/a113311
getOutputType(SubPlan)150%40%335511
getPartitioningProvider(PartitioningHandle)120%n/a113311
lambda$getPartitioningProvider$5(PartitioningHandle)120%n/a111111
getOutputTypeForBroadcastNode()80%20%223311
isBroadcastDistribution(SubPlan)80%n/a111111
lambda$queryCompletedEvent$3(ImmutableList.Builder, SubPlan)80%n/a111111
getRdd(PlanFragmentId)60%n/a111111
lambda$configureOutputPartitioning$6(Session, int, SubPlan)60%n/a111111
lambda$collectPages$2(Map.Entry)60%n/a111111
getFinalFragmentedPlan()50%n/a111111
lambda$collectPages$1(Map.Entry)50%n/a111111
lambda$createPartitioner$0()50%n/a111111
getUpdateType()40%n/a111111
lambda$createRddForSubPlan$7(SubPlan)40%n/a111111
lambda$processShuffleStats$4(AbstractPrestoSparkQueryExecution.ShuffleStatsKey)40%n/a111111
static {...}40%n/a111111