feat: bump df to cd7a00b

Signed-off-by: Ruihang Xia <[email protected]>
GreptimeTeam · Apr 9, 2024 · 7b51de1 · 7b51de1
1 parent ca43688
commit 7b51de1
Show file tree

Hide file tree

Showing 3 changed files with 65 additions and 54 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -96,14 +96,14 @@ bytes = { version = "1.5", features = ["serde"] }
 chrono = { version = "0.4", features = ["serde"] }
 clap = { version = "4.4", features = ["derive"] }
 dashmap = "5.4"
-datafusion = { git = "https://github.com/apache/arrow-datafusion.git", rev = "56c735c458c6d6dd7696941457dd4bbe95eaa2e0" }
-datafusion-common = { git = "https://github.com/apache/arrow-datafusion.git", rev = "56c735c458c6d6dd7696941457dd4bbe95eaa2e0" }
-datafusion-expr = { git = "https://github.com/apache/arrow-datafusion.git", rev = "56c735c458c6d6dd7696941457dd4bbe95eaa2e0" }
-datafusion-functions = { git = "https://github.com/apache/arrow-datafusion.git", rev = "56c735c458c6d6dd7696941457dd4bbe95eaa2e0" }
-datafusion-optimizer = { git = "https://github.com/apache/arrow-datafusion.git", rev = "56c735c458c6d6dd7696941457dd4bbe95eaa2e0" }
-datafusion-physical-expr = { git = "https://github.com/apache/arrow-datafusion.git", rev = "56c735c458c6d6dd7696941457dd4bbe95eaa2e0" }
-datafusion-sql = { git = "https://github.com/apache/arrow-datafusion.git", rev = "56c735c458c6d6dd7696941457dd4bbe95eaa2e0" }
-datafusion-substrait = { git = "https://github.com/apache/arrow-datafusion.git", rev = "56c735c458c6d6dd7696941457dd4bbe95eaa2e0" }
+datafusion = { git = "https://github.com/apache/arrow-datafusion.git", rev = "cd7a00b08309f7229073e4bba686d6271726ab1c" }
+datafusion-common = { git = "https://github.com/apache/arrow-datafusion.git", rev = "cd7a00b08309f7229073e4bba686d6271726ab1c" }
+datafusion-expr = { git = "https://github.com/apache/arrow-datafusion.git", rev = "cd7a00b08309f7229073e4bba686d6271726ab1c" }
+datafusion-functions = { git = "https://github.com/apache/arrow-datafusion.git", rev = "cd7a00b08309f7229073e4bba686d6271726ab1c" }
+datafusion-optimizer = { git = "https://github.com/apache/arrow-datafusion.git", rev = "cd7a00b08309f7229073e4bba686d6271726ab1c" }
+datafusion-physical-expr = { git = "https://github.com/apache/arrow-datafusion.git", rev = "cd7a00b08309f7229073e4bba686d6271726ab1c" }
+datafusion-sql = { git = "https://github.com/apache/arrow-datafusion.git", rev = "cd7a00b08309f7229073e4bba686d6271726ab1c" }
+datafusion-substrait = { git = "https://github.com/apache/arrow-datafusion.git", rev = "cd7a00b08309f7229073e4bba686d6271726ab1c" }
 derive_builder = "0.12"
 dotenv = "0.15"
 # TODO(LFC): Wait for https://github.com/etcdv3/etcd-client/pull/76

diff --git a/src/promql/src/planner.rs b/src/promql/src/planner.rs
@@ -1548,7 +1548,10 @@ impl PromPlanner {
             })),
             token::T_ATAN2 => Ok(Box::new(|lhs, rhs| {
                 Ok(DfExpr::ScalarFunction(ScalarFunction {
-                    func_def: ScalarFunctionDefinition::BuiltIn(BuiltinScalarFunction::Atan2),
+                    // func_def: ScalarFunctionDefinition::BuiltIn(BuiltinScalarFunction::Atan2),
+                    func_def: datafusion_expr::ScalarFunctionDefinition::UDF(
+                        datafusion_functions::math::atan2(),
+                    ),
                     args: vec![lhs, rhs],
                 }))
             })),