rename

Signed-off-by: jayzhan211 <[email protected]>

Author: jayzhan211

datafusion/core/src/physical_planner.rs

@@ -1673,7 +1673,7 @@ pub fn create_aggregate_expr_with_name_and_maybe_filter(
             };
 
             let sort_exprs = order_by.clone().unwrap_or(vec![]);
-            let phy_order_by = match order_by {
+            let order_by = match order_by {
                 Some(e) => Some(
                     e.iter()
                         .map(|expr| {
@@ -1688,9 +1688,9 @@ pub fn create_aggregate_expr_with_name_and_maybe_filter(
                 None => None,
             };
 
-            let (agg_expr, filter, phy_order_by) = match func_def {
+            let (agg_expr, filter, order_by) = match func_def {
                 AggregateFunctionDefinition::BuiltIn(fun) => {
-                    let ordering_reqs = phy_order_by.clone().unwrap_or(vec![]);
+                    let ordering_reqs = order_by.clone().unwrap_or(vec![]);
                     let agg_expr = aggregates::create_aggregate_expr(
                         fun,
                         *distinct,
@@ -1699,11 +1699,11 @@ pub fn create_aggregate_expr_with_name_and_maybe_filter(
                         physical_input_schema,
                         name,
                     )?;
-                    (agg_expr, filter, phy_order_by)
+                    (agg_expr, filter, order_by)
                 }
                 AggregateFunctionDefinition::UDF(fun) => {
                     let ordering_reqs: Vec<PhysicalSortExpr> =
-                        phy_order_by.clone().unwrap_or(vec![]);
+                        order_by.clone().unwrap_or(vec![]);
 
                     let agg_expr = udaf::create_aggregate_expr(
                         fun,
@@ -1713,15 +1713,15 @@ pub fn create_aggregate_expr_with_name_and_maybe_filter(
                         physical_input_schema,
                         name,
                     )?;
-                    (agg_expr, filter, phy_order_by)
+                    (agg_expr, filter, order_by)
                 }
                 AggregateFunctionDefinition::Name(_) => {
                     return internal_err!(
                         "Aggregate function name should have been resolved"
                     )
                 }
             };
-            Ok((agg_expr, filter, phy_order_by))
+            Ok((agg_expr, filter, order_by))
         }
         other => internal_err!("Invalid aggregate expression '{other:?}'"),
     }