(arrow-datafusion) branch main updated: fix build by adding ScalarFunction::ArrayIntersect match (#8136)

[houqp]

This is an automated email from the ASF dual-hosted git repository.

houqp pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git


The following commit(s) were added to refs/heads/main by this push:
     new bd4b3f42e0 fix build by adding ScalarFunction::ArrayIntersect match 
(#8136)
bd4b3f42e0 is described below

commit bd4b3f42e0cc685dcf599bd34596a7f37f0c0510
Author: Huaijin <haohuai...@gmail.com>
AuthorDate: Sat Nov 11 16:00:58 2023 +0800

    fix build by adding ScalarFunction::ArrayIntersect match (#8136)
---
 datafusion/proto/src/logical_plan/from_proto.rs | 18 +++++++++++-------
 1 file changed, 11 insertions(+), 7 deletions(-)

diff --git a/datafusion/proto/src/logical_plan/from_proto.rs 
b/datafusion/proto/src/logical_plan/from_proto.rs
index e5bcc93403..31fffca3bb 100644
--- a/datafusion/proto/src/logical_plan/from_proto.rs
+++ b/datafusion/proto/src/logical_plan/from_proto.rs
@@ -40,13 +40,13 @@ use datafusion_common::{
 };
 use datafusion_expr::{
     abs, acos, acosh, array, array_append, array_concat, array_dims, 
array_element,
-    array_has, array_has_all, array_has_any, array_length, array_ndims, 
array_position,
-    array_positions, array_prepend, array_remove, array_remove_all, 
array_remove_n,
-    array_repeat, array_replace, array_replace_all, array_replace_n, 
array_slice,
-    array_to_string, arrow_typeof, ascii, asin, asinh, atan, atan2, atanh, 
bit_length,
-    btrim, cardinality, cbrt, ceil, character_length, chr, coalesce, 
concat_expr,
-    concat_ws_expr, cos, cosh, cot, current_date, current_time, date_bin, 
date_part,
-    date_trunc, decode, degrees, digest, encode, exp,
+    array_has, array_has_all, array_has_any, array_intersect, array_length, 
array_ndims,
+    array_position, array_positions, array_prepend, array_remove, 
array_remove_all,
+    array_remove_n, array_repeat, array_replace, array_replace_all, 
array_replace_n,
+    array_slice, array_to_string, arrow_typeof, ascii, asin, asinh, atan, 
atan2, atanh,
+    bit_length, btrim, cardinality, cbrt, ceil, character_length, chr, 
coalesce,
+    concat_expr, concat_ws_expr, cos, cosh, cot, current_date, current_time, 
date_bin,
+    date_part, date_trunc, decode, degrees, digest, encode, exp,
     expr::{self, InList, Sort, WindowFunction},
     factorial, flatten, floor, from_unixtime, gcd, isnan, iszero, lcm, left, 
ln, log,
     log10, log2,
@@ -1393,6 +1393,10 @@ pub fn parse_expr(
                     parse_expr(&args[0], registry)?,
                     parse_expr(&args[1], registry)?,
                 )),
+                ScalarFunction::ArrayIntersect => Ok(array_intersect(
+                    parse_expr(&args[0], registry)?,
+                    parse_expr(&args[1], registry)?,
+                )),
                 ScalarFunction::Cardinality => {
                     Ok(cardinality(parse_expr(&args[0], registry)?))
                 }