Upgrade to DataFusion 17.0.0

dask_planner/Cargo.toml

@@ -9,12 +9,12 @@ edition = "2021"
 rust-version = "1.62"
 
 [dependencies]
-arrow = { version = "28.0.0", features = ["prettyprint"] }
+arrow = { version = "29.0.0", features = ["prettyprint"] }
 async-trait = "0.1.61"
-datafusion-common = "15.0.0"
-datafusion-expr = "15.0.0"
-datafusion-optimizer = "15.0.0"
-datafusion-sql = "15.0.0"
+datafusion-common = "16.0.0"
+datafusion-expr = "16.0.0"
+datafusion-optimizer = "16.0.0"
+datafusion-sql = "16.0.0"
 env_logger = "0.10"
 log = "^0.4"
 mimalloc = { version = "*", default-features = false }

dask_planner/src/dialect.rs

@@ -47,7 +47,7 @@ impl Dialect for DaskDialect {
     /// override expression parsing
     fn parse_prefix(&self, parser: &mut Parser) -> Option<Result<Expr, ParserError>> {
         fn parse_expr(parser: &mut Parser) -> Result<Option<Expr>, ParserError> {
-            match parser.peek_token() {
+            match parser.peek_token().token {
                 Token::Word(w) if w.value.to_lowercase() == "ceil" => {
                     // CEIL(d TO DAY)
                     parser.next_token(); // skip ceil