Skip to content

Commit c72fb81

Browse files
committed
format
1 parent cd2dfbd commit c72fb81

1 file changed

Lines changed: 15 additions & 13 deletions

File tree

r/sedonadb/src/rust/src/expression.rs

Lines changed: 15 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -384,20 +384,22 @@ impl SedonaDBExprFactory {
384384
exprs
385385
.iter()
386386
.map(|expr| {
387-
expr.clone().transform_up(|nested_expr| {
388-
match nested_expr {
389-
Expr::AggregateFunction(agg) => {
390-
// Convert to window function with empty OVER ()
391-
let window_func = Expr::WindowFunction(Box::new(WindowFunction::new(
392-
WindowFunctionDefinition::AggregateUDF(agg.func.clone()),
393-
agg.params.args,
394-
)));
395-
Ok(Transformed::yes(window_func))
387+
expr.clone()
388+
.transform_up(|nested_expr| {
389+
match nested_expr {
390+
Expr::AggregateFunction(agg) => {
391+
// Convert to window function with empty OVER ()
392+
let window_func =
393+
Expr::WindowFunction(Box::new(WindowFunction::new(
394+
WindowFunctionDefinition::AggregateUDF(agg.func.clone()),
395+
agg.params.args,
396+
)));
397+
Ok(Transformed::yes(window_func))
398+
}
399+
_ => Ok(Transformed::no(nested_expr)),
396400
}
397-
_ => Ok(Transformed::no(nested_expr)),
398-
}
399-
})
400-
.map(|t| t.data)
401+
})
402+
.map(|t| t.data)
401403
})
402404
.collect()
403405
}

0 commit comments

Comments
 (0)