Upgrade datafusion to version 49 (#140)

Author: nuno-faria

Cargo.toml

@@ -14,7 +14,7 @@ repository = "https://github.com/datafusion-contrib/datafusion-federation"
 arrow-json = "55"
 async-stream = "0.3.5"
 async-trait = "0.1.83"
-datafusion = "48.0.0"
+datafusion = "49.0.0"
 datafusion-federation = { path = "./datafusion-federation", version = "0.4.6" }
 futures = "0.3.31"
 tokio = { version = "1.41", features = ["full"] }

datafusion-federation/src/sql/analyzer.rs

@@ -387,17 +387,14 @@ fn rewrite_table_scans_in_expr(
             let order_by = af
                 .params
                 .order_by
-                .map(|e| {
-                    e.into_iter()
-                        .map(|sort| {
-                            Ok(Sort {
-                                expr: rewrite_table_scans_in_expr(sort.expr, known_rewrites)?,
-                                ..sort
-                            })
-                        })
-                        .collect::<Result<Vec<_>>>()
+                .into_iter()
+                .map(|sort| {
+                    Ok(Sort {
+                        expr: rewrite_table_scans_in_expr(sort.expr, known_rewrites)?,
+                        ..sort
+                    })
                 })
-                .transpose()?;
+                .collect::<Result<Vec<_>>>()?;
             let params = AggregateFunctionParams {
                 args,
                 distinct: af.params.distinct,