Expose metrics from FileSinkExec impl of ExecutionPlan

coralogix · Nov 9, 2023 · 7570f34 · 7570f34
1 parent 2e38489
commit 7570f34
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/datafusion/physical-plan/src/insert.rs b/datafusion/physical-plan/src/insert.rs
@@ -285,6 +285,11 @@ impl ExecutionPlan for FileSinkExec {
             stream,
         )))
     }
+
+    /// Returns the metrics of the underlying [DataSink]
+    fn metrics(&self) -> Option<MetricsSet> {
+        self.sink.metrics()
+    }
 }
 
 /// Create a output record batch with a count