Github user ueshin commented on a diff in the pull request:
https://github.com/apache/spark/pull/21061#discussion_r183011714
--- Diff:
sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/CollectionExpressionsSuite.scala
---
@@ -169,4 +169,45 @@ class CollectionExpressionsSuite extends SparkFunSuite
with ExpressionEvalHelper
checkEvaluation(Reverse(as7), null)
checkEvaluation(Reverse(aa), Seq(Seq("e"), Seq("c", "d"), Seq("a",
"b")))
}
+
+ test("Array Union") {
+ val a00 = Literal.create(Seq(1, 2, 3), ArrayType(IntegerType, false))
+ val a01 = Literal.create(Seq(4, 2), ArrayType(IntegerType, false))
+ val a02 = Literal.create(Seq(1, 2, 3), ArrayType(IntegerType))
+ val a03 = Literal.create(Seq(1, 2, null, 4, 5), ArrayType(IntegerType))
+ val a04 = Literal.create(Seq(-5, 4, -3, 2, -1), ArrayType(IntegerType))
+ val a05 = Literal.create(Seq.empty[Int], ArrayType(IntegerType))
+
+ val a10 = Literal.create(Seq(1L, 2L, 3L), ArrayType(LongType, false))
+ val a11 = Literal.create(Seq(4L, 2L), ArrayType(LongType, false))
+ val a12 = Literal.create(Seq(1L, 2L, 3L), ArrayType(LongType))
+ val a13 = Literal.create(Seq(1L, 2L, null, 4L, 5L),
ArrayType(LongType))
+ val a14 = Literal.create(Seq(-5L, 4L, -3L, 2L, -1L),
ArrayType(LongType))
+ val a15 = Literal.create(Seq.empty[Long], ArrayType(LongType))
+
+ val a20 = Literal.create(Seq("b", "a", "c"), ArrayType(StringType))
+ val a21 = Literal.create(Seq("c", "d", "a", "f"),
ArrayType(StringType))
+ val a22 = Literal.create(Seq("b", null, "a", "g"),
ArrayType(StringType))
+ val a23 = Literal.create(Seq("b", "a", "c"), ArrayType(StringType,
false))
+ val a24 = Literal.create(Seq("c", "d", "a", "f"),
ArrayType(StringType, false))
+
+ val a30 = Literal.create(Seq(null, null), ArrayType(NullType))
+
+ checkEvaluation(ArrayUnion(a00, a01),
UnsafeArrayData.fromPrimitiveArray(Array(4, 1, 3, 2)))
+ checkEvaluation(ArrayUnion(a01, a02), Seq(4, 2, 1, 3))
+ checkEvaluation(ArrayUnion(a03, a04), Seq(1, 2, null, 4, 5, -5, -3,
-1))
+ checkEvaluation(ArrayUnion(a03, a05), Seq(1, 2, null, 4, 5))
+
+ checkEvaluation(
+ ArrayUnion(a10, a11), UnsafeArrayData.fromPrimitiveArray(Array(4L,
1L, 3L, 2L)))
+ checkEvaluation(ArrayUnion(a11, a12), Seq(4L, 2L, 1L, 3L))
+ checkEvaluation(ArrayUnion(a13, a14), Seq(1L, 2L, null, 4L, 5L, -5L,
-3L, -1L))
+ checkEvaluation(ArrayUnion(a13, a15), Seq(1L, 2L, null, 4L, 5L))
+
+ checkEvaluation(ArrayUnion(a20, a21), Seq("b", "a", "c", "d", "f"))
+ checkEvaluation(ArrayUnion(a20, a22), Seq("b", "a", "c", null, "g"))
+ checkEvaluation(ArrayUnion(a23, a24), Seq("b", "c", "d", "a", "f"))
+
+ checkEvaluation(ArrayUnion(a30, a30), Seq(null))
--- End diff --
Ah, I see. Maybe the purpose of the test is not what I thought.
Seems like what I wanted is included in the latest updates.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
