Skip to content

Commit

Permalink
fix style
Browse files Browse the repository at this point in the history
  • Loading branch information
huaxingao committed Aug 10, 2024
1 parent 37c7f9f commit 46c40b3
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions native/core/src/execution/datafusion/planner.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1493,7 +1493,7 @@ impl PhysicalPlanner {

fn convert_count_to_if(
&self,
children: &Vec<Expr>,
children: &[Expr],
schema: Arc<Schema>,
) -> Result<Arc<dyn PhysicalExpr>, ExecutionError> {
assert!(!children.is_empty(), "Children should not be empty");
Expand Down Expand Up @@ -1533,12 +1533,12 @@ impl PhysicalPlanner {
partition_by: &[Arc<dyn PhysicalExpr>],
sort_exprs: &[PhysicalSortExpr],
) -> Result<Arc<dyn WindowExpr>, ExecutionError> {
let (mut window_func_name, mut window_args): (String, Vec<Arc<dyn PhysicalExpr>>) =
(String::new(), Vec::new());
let window_func_name: String;
let window_args: Vec<Arc<dyn PhysicalExpr>>;
if let Some(func) = &spark_expr.built_in_window_function {
match &func.expr_struct {
Some(ExprStruct::ScalarFunc(f)) => {
window_func_name.clone_from(&f.func);
window_func_name = f.func.clone();
window_args = f
.args
.iter()
Expand Down

0 comments on commit 46c40b3

Please sign in to comment.