feat: implement to_time

Author: parthchandra

native/spark-expr/src/comet_scalar_funcs.rs

@@ -23,10 +23,11 @@ use crate::math_funcs::log::spark_log;
 use crate::math_funcs::modulo_expr::spark_modulo;
 use crate::{
     spark_ceil, spark_decimal_div, spark_decimal_integral_div, spark_floor, spark_isnan,
-    spark_lpad, spark_make_decimal, spark_read_side_padding, spark_round, spark_rpad, spark_unhex,
-    spark_unscaled_value, EvalMode, SparkArrayCompact, SparkArrayPositionFunc, SparkArraysOverlap,
-    SparkContains, SparkDateDiff, SparkDateFromUnixDate, SparkDateTrunc, SparkMakeDate,
-    SparkMakeTime, SparkSecondsToTimestamp, SparkSizeFunc,
+    spark_lpad, spark_make_decimal, spark_read_side_padding, spark_round, spark_rpad,
+    spark_to_time, spark_unhex, spark_unscaled_value, EvalMode, SparkArrayCompact,
+    SparkArrayPositionFunc, SparkArraysOverlap, SparkContains, SparkDateDiff,
+    SparkDateFromUnixDate, SparkDateTrunc, SparkMakeDate, SparkMakeTime,
+    SparkSecondsToTimestamp, SparkSizeFunc,
 };
 use arrow::datatypes::DataType;
 use datafusion::common::{DataFusionError, Result as DataFusionResult};
@@ -196,6 +197,9 @@ pub fn create_comet_physical_fun_with_eval_mode(
             let func = Arc::new(spark_map_sort);
             make_comet_scalar_udf!("spark_map_sort", func, without data_type)
         }
+        "to_time" => {
+            make_comet_scalar_udf!("to_time", spark_to_time, without data_type, fail_on_error)
+        }
         _ => registry.udf(fun_name).map_err(|e| {
             DataFusionError::Execution(format!(
                 "Function {fun_name} not found in the registry: {e}",

native/spark-expr/src/datetime_funcs/mod.rs

@@ -23,6 +23,7 @@ mod hours;
 mod make_date;
 mod make_time;
 mod seconds_to_timestamp;
+mod to_time;
 mod timestamp_trunc;
 mod unix_timestamp;
 
@@ -36,5 +37,6 @@ pub use hours::SparkHoursTransform;
 pub use make_date::SparkMakeDate;
 pub use make_time::SparkMakeTime;
 pub use seconds_to_timestamp::SparkSecondsToTimestamp;
+pub use to_time::{spark_to_time, to_time_return_type};
 pub use timestamp_trunc::TimestampTruncExpr;
 pub use unix_timestamp::SparkUnixTimestamp;