fix style

huaxingao · Mar 19, 2024 · 5a4b4d5 · 5a4b4d5
1 parent 9c38d21
commit 5a4b4d5
Showing 1 changed file with 15 additions and 4 deletions.
diff --git a/core/src/execution/datafusion/planner.rs b/core/src/execution/datafusion/planner.rs
@@ -28,8 +28,9 @@ use datafusion::{
         execution_props::ExecutionProps,
         expressions::{
             in_list, BinaryExpr, BitAnd, BitOr, BitXor, CaseExpr, CastExpr, Column, Count,
-            Covariance, CovariancePop, FirstValue, InListExpr, IsNotNullExpr, IsNullExpr, LastValue,
-            Literal as DataFusionLiteral, Max, Min, NegativeExpr, NotExpr, Sum, UnKnownColumn,
+            Covariance, CovariancePop, FirstValue, InListExpr, IsNotNullExpr, IsNullExpr,
+            LastValue, Literal as DataFusionLiteral, Max, Min, NegativeExpr, NotExpr, Sum,
+            UnKnownColumn,
         },
         functions::create_physical_expr,
         AggregateExpr, PhysicalExpr, PhysicalSortExpr, ScalarFunctionExpr,
@@ -1051,13 +1052,23 @@ impl PhysicalPlanner {
                 let child1 = self.create_expr(expr.child1.as_ref().unwrap(), schema.clone())?;
                 let child2 = self.create_expr(expr.child2.as_ref().unwrap(), schema.clone())?;
                 let datatype = to_arrow_datatype(expr.datatype.as_ref().unwrap());
-                Ok(Arc::new(Covariance::new(child1, child2, "covariance", datatype)))
+                Ok(Arc::new(Covariance::new(
+                    child1,
+                    child2,
+                    "covariance",
+                    datatype,
+                )))
             }
             AggExprStruct::CovPopulation(expr) => {
                 let child1 = self.create_expr(expr.child1.as_ref().unwrap(), schema.clone())?;
                 let child2 = self.create_expr(expr.child2.as_ref().unwrap(), schema.clone())?;
                 let datatype = to_arrow_datatype(expr.datatype.as_ref().unwrap());
-                Ok(Arc::new(CovariancePop::new(child1, child2, "covariance_pop", datatype)))
+                Ok(Arc::new(CovariancePop::new(
+                    child1,
+                    child2,
+                    "covariance_pop",
+                    datatype,
+                )))
             }
         }
     }