Skip to content

Commit ded06b5

Browse files
committed
feat: [1941-Part3]: Introduce map_from_list scalar function
1 parent ffa65a3 commit ded06b5

File tree

3 files changed

+736
-0
lines changed

3 files changed

+736
-0
lines changed

native/spark-expr/src/comet_scalar_funcs.rs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
// under the License.
1717

1818
use crate::hash_funcs::*;
19+
use crate::map_funcs::map_from_list;
1920
use crate::map_funcs::spark_map_sort;
2021
use crate::math_funcs::checked_arithmetic::{checked_add, checked_div, checked_mul, checked_sub};
2122
use crate::math_funcs::modulo_expr::spark_modulo;
@@ -162,6 +163,10 @@ pub fn create_comet_physical_fun(
162163
let func = Arc::new(spark_map_sort);
163164
make_comet_scalar_udf!("spark_map_sort", func, without data_type)
164165
}
166+
"map_from_list" => {
167+
let func = Arc::new(map_from_list);
168+
make_comet_scalar_udf!("map_from_list", func, without data_type)
169+
}
165170
_ => registry.udf(fun_name).map_err(|e| {
166171
DataFusionError::Execution(format!(
167172
"Function {fun_name} not found in the registry: {e}",

0 commit comments

Comments
 (0)