execute() |  | 0% |  | 0% | 22 | 22 | 72 | 72 | 1 | 1 |
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) |  | 0% | | n/a | 1 | 1 | 40 | 40 | 1 | 1 |
collectPages(TableWriteInfo, PlanFragment, Map) |  | 0% |  | 0% | 3 | 3 | 42 | 42 | 1 | 1 |
logShuffleStatsSummary(AbstractPrestoSparkQueryExecution.ShuffleStatsKey, List) |  | 0% |  | 0% | 5 | 5 | 37 | 37 | 1 | 1 |
createRddForSubPlan(SubPlan, TableWriteInfo, Optional) |  | 0% |  | 0% | 5 | 5 | 25 | 25 | 1 | 1 |
queryCompletedEvent(Optional, OptionalLong) |  | 0% |  | 0% | 4 | 4 | 25 | 25 | 1 | 1 |
createRdd(SubPlan, Class, TableWriteInfo) |  | 0% |  | 0% | 4 | 4 | 22 | 22 | 1 | 1 |
createBroadcastDependency(RddAndMore) |  | 0% |  | 0% | 4 | 4 | 18 | 18 | 1 | 1 |
processBootstrapStats() |  | 0% |  | 0% | 5 | 5 | 18 | 18 | 1 | 1 |
checkPageSinkCommitIsSupported(Session, ExecutionWriterTarget) |  | 0% |  | 0% | 7 | 7 | 14 | 14 | 1 | 1 |
createPartitioner(PartitioningScheme) |  | 0% |  | 0% | 6 | 6 | 13 | 13 | 1 | 1 |
processShuffleStats() |  | 0% |  | 0% | 3 | 3 | 12 | 12 | 1 | 1 |
executeFragment(SubPlan, TableWriteInfo, Optional) |  | 0% |  | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
configureOutputPartitioning(Session, SubPlan, int) |  | 0% |  | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
getBucketToPartition(Session, PartitioningHandle, int) |  | 0% |  | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
partitionBy(int, JavaPairRDD, PartitioningScheme) |  | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
getTableWriteInfo(Session, SubPlan) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
validateStorageCapabilities(TempStorage) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
setFinalFragmentedPlan(SubPlan) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
getTableWriteInfo(Session, PlanNode) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
tuneMaxExecutorsCount() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
getPartitionCount(Session, PartitioningHandle) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
getOutputTypes() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getOutputType(SubPlan) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
getPartitioningProvider(PartitioningHandle) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$getPartitioningProvider$5(PartitioningHandle) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getOutputTypeForBroadcastNode() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
isBroadcastDistribution(SubPlan) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$queryCompletedEvent$3(ImmutableList.Builder, SubPlan) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getRdd(PlanFragmentId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$configureOutputPartitioning$6(Session, int, SubPlan) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$collectPages$2(Map.Entry) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getFinalFragmentedPlan() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$collectPages$1(Map.Entry) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$createPartitioner$0() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getUpdateType() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$createRddForSubPlan$7(SubPlan) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$processShuffleStats$4(AbstractPrestoSparkQueryExecution.ShuffleStatsKey) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |