From d536c2b615bc706e93458578884f9179f22b0805 Mon Sep 17 00:00:00 2001 From: Rui Mo Date: Tue, 4 Nov 2025 23:19:39 +0800 Subject: [PATCH] Add waitForPreloadSplitNanos --- cpp/velox/compute/WholeStageResultIterator.cc | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/cpp/velox/compute/WholeStageResultIterator.cc b/cpp/velox/compute/WholeStageResultIterator.cc index faae3aeffbd..1766654f3d9 100644 --- a/cpp/velox/compute/WholeStageResultIterator.cc +++ b/cpp/velox/compute/WholeStageResultIterator.cc @@ -54,6 +54,7 @@ const std::string kRamReadBytes = "ramReadBytes"; const std::string kPreloadSplits = "readyPreloadedSplits"; const std::string kPageLoadTime = "pageLoadTimeNs"; const std::string kDataSourceAddSplitWallNanos = "dataSourceAddSplitWallNanos"; +const std::string kWaitForPreloadSplitNanos = "waitForPreloadSplitNanos"; const std::string kDataSourceReadWallNanos = "dataSourceReadWallNanos"; const std::string kNumWrittenFiles = "numWrittenFiles"; const std::string kWriteIOTime = "writeIOWallNanos"; @@ -478,7 +479,8 @@ void WholeStageResultIterator::collectMetrics() { runtimeMetric("sum", entry.second->customStats, kPreloadSplits); metrics_->get(Metrics::kPageLoadTime)[metricIndex] = runtimeMetric("sum", second->customStats, kPageLoadTime); metrics_->get(Metrics::kDataSourceAddSplitWallNanos)[metricIndex] = - runtimeMetric("sum", second->customStats, kDataSourceAddSplitWallNanos); + runtimeMetric("sum", second->customStats, kDataSourceAddSplitWallNanos) + + runtimeMetric("sum", second->customStats, kWaitForPreloadSplitNanos); metrics_->get(Metrics::kDataSourceReadWallNanos)[metricIndex] = runtimeMetric("sum", second->customStats, kDataSourceReadWallNanos); metrics_->get(Metrics::kNumWrittenFiles)[metricIndex] =