davidradl commented on code in PR #24526:
URL: https://github.com/apache/flink/pull/24526#discussion_r1611983897
##########
flink-python/pyflink/table/expression.py:
##########
@@ -1618,6 +1618,15 @@ def array_except(self, array) -> 'Expression':
"""
return _binary_op("arrayExcept")(self, array)
+ def array_intersect(self, array) -> 'Expression':
+ """
+ Returns an ARRAY that contains the elements from array1 that are also
in array2.
+ If no elements are both in array1 and array2, the function returns an
empty ARRAY.
+ If one or both arguments are NULL, the function returns NULL.
+ The order of the elements from array1 is kept.
Review Comment:
this should mention the deduplication behaviour
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
