fmt

Author: adriangb

datafusion/datasource-parquet/src/source.rs

@@ -612,10 +612,9 @@ impl FileSource for ParquetSource {
         let pushdown_filters = table_pushdown_enabled || config_pushdown_enabled;
 
         let mut source = self.clone();
-        let filters = PredicateSupports::new_with_supported_check(
-            filters,
-            |filter| pushdown_filters && can_expr_be_pushed_down_with_schemas(filter, &file_schema),
-        );
+        let filters = PredicateSupports::new_with_supported_check(filters, |filter| {
+            pushdown_filters && can_expr_be_pushed_down_with_schemas(filter, &file_schema)
+        });
         if filters.is_all_unsupported() {
             // No filters can be pushed down, so we can just return the remaining filters
             // and avoid replacing the source in the physical plan.

datafusion/physical-plan/src/execution_plan.rs

@@ -535,11 +535,11 @@ pub trait ExecutionPlan: Debug + DisplayAs + Send + Sync {
     /// and [`ChildPushdownResult::self_filters`] is discarded.
     ///
     /// The default implementation is a no-op that passes the result of pushdown from the children to its parent.
-    /// 
+    ///
     /// When returning filters via [`FilterPushdownPropagation`] the order of the filters need not match
     /// the order they were passed in via `child_pushdown_result`, but preserving the order may be beneficial
     /// for debugging and reasoning about the resulting plans so it is recommended to preserve the order.
-    /// 
+    ///
     /// There are various helper methods to make implementing this method easier, see:
     /// - [`FilterPushdownPropagation::unsupported`]: to indicate that the node does not support filter pushdown at all.
     /// - [`FilterPushdownPropagation::transparent`]: to indicate that the node supports filter pushdown but does not involve itself in it,

datafusion/physical-plan/src/filter_pushdown.rs

@@ -166,12 +166,16 @@ impl PredicateSupports {
 
     /// Check if all filters are supported.
     pub fn is_all_supported(&self) -> bool {
-        self.0.iter().all(|f| matches!(f, PredicateSupport::Supported(_)))
+        self.0
+            .iter()
+            .all(|f| matches!(f, PredicateSupport::Supported(_)))
     }
 
     /// Check if all filters are unsupported.
     pub fn is_all_unsupported(&self) -> bool {
-        self.0.iter().all(|f| matches!(f, PredicateSupport::Unsupported(_)))
+        self.0
+            .iter()
+            .all(|f| matches!(f, PredicateSupport::Unsupported(_)))
     }
 }