From c9dbfcc653b868fdb28106c1d1bcb6cb6caac6cc Mon Sep 17 00:00:00 2001
From: Liang-Chi Hsieh <viirya@gmail.com>
Date: Thu, 31 Dec 2015 23:48:05 -0800
Subject: [PATCH] [SPARK-11743][SQL] Move the test for arrayOfUDT
A following pr for #9712. Move the test for arrayOfUDT.
Author: Liang-Chi Hsieh <viirya@gmail.com>
Closes #10538 from viirya/move-udt-test.
---
.../sql/catalyst/encoders/RowEncoderSuite.scala | 15 ++-------------
1 file changed, 2 insertions(+), 13 deletions(-)
diff --git a/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/encoders/RowEncoderSuite.scala b/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/encoders/RowEncoderSuite.scala
index 0ea51ece4b..8f4faab7ba 100644
--- a/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/encoders/RowEncoderSuite.scala
+++ b/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/encoders/RowEncoderSuite.scala
@@ -108,7 +108,8 @@ class RowEncoderSuite extends SparkFunSuite {
.add("arrayOfArrayOfString", ArrayType(arrayOfString))
.add("arrayOfArrayOfInt", ArrayType(ArrayType(IntegerType)))
.add("arrayOfMap", ArrayType(mapOfString))
- .add("arrayOfStruct", ArrayType(structOfString)))
+ .add("arrayOfStruct", ArrayType(structOfString))
+ .add("arrayOfUDT", arrayOfUDT))
encodeDecodeTest(
new StructType()
@@ -130,18 +131,6 @@ class RowEncoderSuite extends SparkFunSuite {
new StructType().add("array", arrayOfString).add("map", mapOfString))
.add("structOfUDT", structOfUDT))
- test(s"encode/decode: arrayOfUDT") {
- val schema = new StructType()
- .add("arrayOfUDT", arrayOfUDT)
-
- val encoder = RowEncoder(schema)
-
- val input: Row = Row(Seq(new ExamplePoint(0.1, 0.2), new ExamplePoint(0.3, 0.4)))
- val row = encoder.toRow(input)
- val convertedBack = encoder.fromRow(row)
- assert(input.getSeq[ExamplePoint](0) == convertedBack.getSeq[ExamplePoint](0))
- }
-
test(s"encode/decode: Product") {
val schema = new StructType()
.add("structAsProduct",
--
GitLab