From 5a4b4d5f91e8c54851ab394b7303b82c25b8487d Mon Sep 17 00:00:00 2001 From: Huaxin Gao Date: Tue, 19 Mar 2024 12:59:07 -0700 Subject: [PATCH] fix style --- core/src/execution/datafusion/planner.rs | 19 +++++++++++++++---- 1 file changed, 15 insertions(+), 4 deletions(-) diff --git a/core/src/execution/datafusion/planner.rs b/core/src/execution/datafusion/planner.rs index 711e40fc37..120134d5c9 100644 --- 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, + ))) } } }