This is an automated email from the ASF dual-hosted git repository.
alamb pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion.git
The following commit(s) were added to refs/heads/main by this push:
new 0b8da6d6e7 Rename RepartitionExec metric `repart_time` to
`repartition_time` (#11703)
0b8da6d6e7 is described below
commit 0b8da6d6e75e2384a40c65f089ec17219f36b2ff
Author: Andrew Lamb <[email protected]>
AuthorDate: Thu Aug 1 07:29:12 2024 -0400
Rename RepartitionExec metric `repart_time` to `repartition_time` (#11703)
* Rename RepartitionExec metric `repart_time` to `repartition_time`
* Update datafusion/physical-plan/src/repartition/mod.rs
Co-authored-by: Oleks V <[email protected]>
* fmt
---------
Co-authored-by: Oleks V <[email protected]>
---
datafusion/physical-plan/src/repartition/mod.rs | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git a/datafusion/physical-plan/src/repartition/mod.rs
b/datafusion/physical-plan/src/repartition/mod.rs
index f09324c401..656d82215b 100644
--- a/datafusion/physical-plan/src/repartition/mod.rs
+++ b/datafusion/physical-plan/src/repartition/mod.rs
@@ -414,8 +414,8 @@ pub struct RepartitionExec {
struct RepartitionMetrics {
/// Time in nanos to execute child operator and fetch batches
fetch_time: metrics::Time,
- /// Time in nanos to perform repartitioning
- repart_time: metrics::Time,
+ /// Repartitioning elapsed time in nanos
+ repartition_time: metrics::Time,
/// Time in nanos for sending resulting batches to channels.
///
/// One metric per output partition.
@@ -433,8 +433,8 @@ impl RepartitionMetrics {
MetricBuilder::new(metrics).subset_time("fetch_time",
input_partition);
// Time in nanos to perform repartitioning
- let repart_time =
- MetricBuilder::new(metrics).subset_time("repart_time",
input_partition);
+ let repartition_time =
+ MetricBuilder::new(metrics).subset_time("repartition_time",
input_partition);
// Time in nanos for sending resulting batches to channels
let send_time = (0..num_output_partitions)
@@ -449,7 +449,7 @@ impl RepartitionMetrics {
Self {
fetch_time,
- repart_time,
+ repartition_time,
send_time,
}
}
@@ -775,7 +775,7 @@ impl RepartitionExec {
context: Arc<TaskContext>,
) -> Result<()> {
let mut partitioner =
- BatchPartitioner::try_new(partitioning,
metrics.repart_time.clone())?;
+ BatchPartitioner::try_new(partitioning,
metrics.repartition_time.clone())?;
// execute the child operator
let timer = metrics.fetch_time.timer();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
