better naming

coralogix · Nov 4, 2024 · fab7e66 · fab7e66
1 parent 6d023f8
commit fab7e66
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/datafusion/physical-plan/src/aggregates/row_hash.rs b/datafusion/physical-plan/src/aggregates/row_hash.rs
@@ -61,7 +61,7 @@ struct AggregateStreamMetrics {
     processing_time: Time,
     idle_time: Time,
     last_batch_at: Instant,
-    waiting_time: Time,
+    wait_time: Time,
 }
 
 impl AggregateStreamMetrics {
@@ -71,8 +71,7 @@ impl AggregateStreamMetrics {
                 .subset_time("processing_time", partition),
             idle_time: MetricBuilder::new(metrics).subset_time("idle_time", partition),
             last_batch_at: Instant::now(),
-            waiting_time: MetricBuilder::new(metrics)
-                .subset_time("waiting_time", partition),
+            wait_time: MetricBuilder::new(metrics).subset_time("wait_time", partition),
         }
     }
 
@@ -456,11 +455,11 @@ impl Stream for GroupedHashAggregateStream {
         loop {
             match &self.exec_state {
                 ExecutionState::ReadingInput => 'reading_input: {
-                    let wait_started = Instant::now();
+                    let started = Instant::now();
                     let result = ready!(self.input.poll_next_unpin(cx));
                     self.aggregate_stream_metrics
-                        .waiting_time
-                        .add_duration(wait_started.elapsed());
+                        .wait_time
+                        .add_duration(started.elapsed());
                     match result {
                         // new batch to aggregate
                         Some(Ok(batch)) => {