From 25c077db65db2f2110036ab173fa4fb3f5bdfc01 Mon Sep 17 00:00:00 2001 From: PHILO-HE Date: Sat, 6 Apr 2024 12:01:04 +0800 Subject: [PATCH] Initial commit --- velox/functions/sparksql/Register.cpp | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/velox/functions/sparksql/Register.cpp b/velox/functions/sparksql/Register.cpp index 72a8ca527568..ee9a8b4cc0a1 100644 --- a/velox/functions/sparksql/Register.cpp +++ b/velox/functions/sparksql/Register.cpp @@ -94,6 +94,10 @@ static void workAroundRegistrationMacro(const std::string& prefix) { VELOX_REGISTER_VECTOR_FUNCTION(udf_array_contains, prefix + "array_contains"); VELOX_REGISTER_VECTOR_FUNCTION( udf_array_intersect, prefix + "array_intersect"); + VELOX_REGISTER_VECTOR_FUNCTION(udf_array_distinct, prefix + "array_distinct"); + VELOX_REGISTER_VECTOR_FUNCTION(udf_array_except, prefix + "array_except"); + VELOX_REGISTER_VECTOR_FUNCTION(udf_array_position, prefix + "array_position"); + // This is the semantics of spark.sql.ansi.enabled = false. registerElementAtFunction(prefix + "element_at", true);