remove unecessary self parameter

apache · Nov 1, 2022 · 3176d02 · 3176d02
1 parent 287790f
commit 3176d02
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 5 deletions.
diff --git a/datafusion/core/tests/parquet_filter_pushdown.rs b/datafusion/core/tests/parquet_filter_pushdown.rs
@@ -399,9 +399,8 @@ impl TestCase {
         assert_eq!(total_rows, self.expected_rows);
 
         // verify expected pushdown
-        let metrics = test_file
-            .parquet_metrics(exec)
-            .expect("found parquet metrics");
+        let metrics =
+            TestParquetFile::parquet_metrics(exec).expect("found parquet metrics");
         let pushdown_rows_filtered = get_value(&metrics, "pushdown_rows_filtered");
         println!("  pushdown_rows_filtered: {}", pushdown_rows_filtered);
 

diff --git a/parquet-test-utils/src/lib.rs b/parquet-test-utils/src/lib.rs
@@ -189,13 +189,13 @@ impl TestParquetFile {
     ///
     /// Recursively searches for ParquetExec and returns the metrics
     /// on the first one it finds
-    pub fn parquet_metrics(&self, plan: Arc<dyn ExecutionPlan>) -> Option<MetricsSet> {
+    pub fn parquet_metrics(plan: Arc<dyn ExecutionPlan>) -> Option<MetricsSet> {
         if let Some(parquet) = plan.as_any().downcast_ref::<ParquetExec>() {
             return parquet.metrics();
         }
 
         for child in plan.children() {
-            if let Some(metrics) = self.parquet_metrics(child) {
+            if let Some(metrics) = TestParquetFile::parquet_metrics(child) {
                 return Some(metrics);
             }
         }