Cargo fmt

apache · Dec 13, 2024 · 48ef66a · 48ef66a
1 parent 2e25277
commit 48ef66a
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 5 deletions.
diff --git a/datafusion/physical-expr/src/equivalence/class.rs b/datafusion/physical-expr/src/equivalence/class.rs
@@ -636,8 +636,15 @@ impl EquivalenceGroup {
     }
 
     /// Checks if two expressions are equal either directly or through equivalence classes.
-    pub fn exprs_equal(&self, left: &Arc<dyn PhysicalExpr>, right: &Arc<dyn PhysicalExpr>) -> bool {
-        left.eq(right) || self.iter().any(|cls| cls.contains(left) && cls.contains(right))
+    pub fn exprs_equal(
+        &self,
+        left: &Arc<dyn PhysicalExpr>,
+        right: &Arc<dyn PhysicalExpr>,
+    ) -> bool {
+        left.eq(right)
+            || self
+                .iter()
+                .any(|cls| cls.contains(left) && cls.contains(right))
     }
 }
 

diff --git a/datafusion/physical-expr/src/equivalence/properties.rs b/datafusion/physical-expr/src/equivalence/properties.rs
@@ -398,7 +398,7 @@ impl EquivalenceProperties {
             sort_exprs
                 .into_iter()
                 .filter(|expr| !self.is_expr_constant(&expr.expr))
-                .collect()
+                .collect(),
         );
 
         if filtered_exprs.is_empty() {
@@ -430,8 +430,8 @@ impl EquivalenceProperties {
 
         // Check if new order matches existing prefix (considering equivalences)
         new_order.iter().zip(existing).all(|(new, existing)| {
-            self.eq_group.exprs_equal(&new.expr, &existing.expr) &&
-            new.options == existing.options
+            self.eq_group.exprs_equal(&new.expr, &existing.expr)
+                && new.options == existing.options
         })
     }