Snowflake timestamp_from_parts udf (#297)

* Inital version

* snowflake timestamp_from_parts udf

* Fix clippy

* Fix example typo

* Support negative values

Author: osipovartem

Cargo.toml

@@ -42,6 +42,8 @@ datafusion = { version = "45.0.0" }
 datafusion-common = { version = "45.0.0" }
 datafusion-expr = { version = "45.0.0" }
 datafusion-physical-plan = { version = "45.0.0" }
+datafusion-doc = { version = "45.0.0" }
+datafusion-macros = { version = "45.0.0" }
 
 # do not change iceberg-rust, datafusion-functions-json hash commits unless datafusion version bumped
 datafusion-functions-json = { git = "https://github.com/Embucket/datafusion-functions-json.git", rev = "f2b9b88cd9b4282bc0286a970333e8c01cec177b" }
@@ -54,6 +56,8 @@ datafusion = { git = "https://github.com/Embucket/datafusion.git", rev = "314a72
 datafusion-common = { git = "https://github.com/Embucket/datafusion.git", rev = "314a72634dc4f15242345fd17dc32df6c3ae04e8" }
 datafusion-expr = { git = "https://github.com/Embucket/datafusion.git", rev = "314a72634dc4f15242345fd17dc32df6c3ae04e8" }
 datafusion-physical-plan = { git = "https://github.com/Embucket/datafusion.git", rev = "314a72634dc4f15242345fd17dc32df6c3ae04e8" }
+datafusion-doc = { git = "https://github.com/Embucket/datafusion.git", rev = "314a72634dc4f15242345fd17dc32df6c3ae04e8" }
+datafusion-macros = { git = "https://github.com/Embucket/datafusion.git", rev = "314a72634dc4f15242345fd17dc32df6c3ae04e8" }
 
 [workspace.lints.clippy]
 all = { level = "deny", priority = -1 }

crates/runtime/Cargo.toml

@@ -19,6 +19,8 @@ datafusion-common = { workspace = true }
 datafusion-expr = { workspace = true }
 datafusion-functions-json = { workspace = true }
 datafusion-physical-plan = { workspace = true }
+datafusion-doc = { workspace = true }
+datafusion-macros = { workspace = true }
 datafusion_iceberg = { workspace = true }
 
 futures = { workspace = true }

crates/runtime/src/datafusion/functions/mod.rs

@@ -23,13 +23,15 @@ mod convert_timezone;
 mod date_add;
 mod date_diff;
 mod parse_json;
+mod timestamp_from_parts;
 
 pub fn register_udfs(registry: &mut dyn FunctionRegistry) -> Result<()> {
     let functions: Vec<Arc<ScalarUDF>> = vec![
         convert_timezone::get_udf(),
         date_add::get_udf(),
         parse_json::get_udf(),
         date_diff::get_udf(),
+        timestamp_from_parts::get_udf(),
     ];
 
     for func in functions {