fmt

Author: adriangb

datafusion/datasource-parquet/benches/parquet_nested_filter_pushdown.rs

@@ -115,13 +115,9 @@ fn scan_with_predicate(
     let file_metrics = ParquetFileMetrics::new(0, &path.display().to_string(), &metrics);
 
     let builder = if pushdown {
-        if let Some(row_filter) = build_row_filter(
-            predicate,
-            file_schema,
-            &metadata,
-            false,
-            &file_metrics,
-        )? {
+        if let Some(row_filter) =
+            build_row_filter(predicate, file_schema, &metadata, false, &file_metrics)?
+        {
             builder.with_row_filter(row_filter)
         } else {
             builder

datafusion/datasource-parquet/src/opener.rs

@@ -296,10 +296,16 @@ struct PreparedParquetOpen {
     output_schema: SchemaRef,
     projection: ProjectionExprs,
     predicate: Option<Arc<dyn PhysicalExpr>>,
-    #[expect(dead_code, reason = "wired through but not yet consumed by upstream opener state machine")]
+    #[expect(
+        dead_code,
+        reason = "wired through but not yet consumed by upstream opener state machine"
+    )]
     predicate_conjuncts:
         Option<Vec<(crate::selectivity::FilterId, Arc<dyn PhysicalExpr>)>>,
-    #[expect(dead_code, reason = "to be threaded into build_row_filter in follow-up")]
+    #[expect(
+        dead_code,
+        reason = "to be threaded into build_row_filter in follow-up"
+    )]
     selectivity_tracker: Arc<crate::selectivity::SelectivityTracker>,
     pushdown_filters: bool,
     force_filter_selections: bool,