diff options
author | Liang-Chi Hsieh <viirya@gmail.com> | 2015-12-31 23:48:05 -0800 |
---|---|---|
committer | Reynold Xin <rxin@databricks.com> | 2015-12-31 23:48:05 -0800 |
commit | c9dbfcc653b868fdb28106c1d1bcb6cb6caac6cc (patch) | |
tree | 4cc052ff1cf458a73a9af2a5a0c08b9b7c308571 | |
parent | 5adec63a922d6f60cd6cb87ebdab61a17131ac1a (diff) | |
download | spark-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.
-rw-r--r-- | sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/encoders/RowEncoderSuite.scala | 15 |
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", |