aboutsummaryrefslogtreecommitdiff
path: root/sql
diff options
context:
space:
mode:
authorLiang-Chi Hsieh <viirya@gmail.com>2015-12-31 23:48:05 -0800
committerReynold Xin <rxin@databricks.com>2015-12-31 23:48:05 -0800
commitc9dbfcc653b868fdb28106c1d1bcb6cb6caac6cc (patch)
tree4cc052ff1cf458a73a9af2a5a0c08b9b7c308571 /sql
parent5adec63a922d6f60cd6cb87ebdab61a17131ac1a (diff)
downloadspark-c9dbfcc653b868fdb28106c1d1bcb6cb6caac6cc.tar.gz
spark-c9dbfcc653b868fdb28106c1d1bcb6cb6caac6cc.tar.bz2
spark-c9dbfcc653b868fdb28106c1d1bcb6cb6caac6cc.zip
[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.
Diffstat (limited to 'sql')
-rw-r--r--sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/encoders/RowEncoderSuite.scala15
1 files 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",