Skip to content

Commit b36b864

Browse files
committed
upd to datafusion 48
1 parent 8b3c80c commit b36b864

2 files changed

Lines changed: 4 additions & 4 deletions

File tree

Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ repository = "https://github.com/datafusion-contrib/datafusion-federation"
1414
arrow-json = "55"
1515
async-stream = "0.3.5"
1616
async-trait = "0.1.83"
17-
datafusion = "47.0.0"
17+
datafusion = "48.0.0"
1818
datafusion-federation = { path = "./datafusion-federation", version = "0.4.2" }
1919
futures = "0.3.31"
2020
tokio = { version = "1.41", features = ["full"] }

datafusion-federation/src/sql/analyzer.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -441,10 +441,10 @@ fn rewrite_table_scans_in_expr(
441441
window_frame: wf.params.window_frame,
442442
null_treatment: wf.params.null_treatment,
443443
};
444-
Ok(Expr::WindowFunction(WindowFunction {
444+
Ok(Expr::WindowFunction(Box::new(WindowFunction {
445445
fun: wf.fun,
446446
params,
447-
}))
447+
})))
448448
}
449449
Expr::InList(il) => {
450450
let expr = rewrite_table_scans_in_expr(*il.expr, known_rewrites)?;
@@ -563,7 +563,7 @@ fn rewrite_table_scans_in_expr(
563563
let expr = rewrite_table_scans_in_expr(*unnest.expr, known_rewrites)?;
564564
Ok(Expr::Unnest(Unnest::new(expr)))
565565
}
566-
Expr::ScalarVariable(_, _) | Expr::Literal(_) | Expr::Placeholder(_) => Ok(expr),
566+
Expr::ScalarVariable(_, _) | Expr::Literal(_, _) | Expr::Placeholder(_) => Ok(expr),
567567
}
568568
}
569569

0 commit comments

Comments
 (0)