You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2016/01/01 08:48:08 UTC
spark git commit: [SPARK-11743][SQL] Move the test for arrayOfUDT
Repository: spark
Updated Branches:
refs/heads/master 5adec63a9 -> c9dbfcc65
[SPARK-11743][SQL] Move the test for arrayOfUDT
A following pr for #9712. Move the test for arrayOfUDT.
Author: Liang-Chi Hsieh <vi...@gmail.com>
Closes #10538 from viirya/move-udt-test.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/c9dbfcc6
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/c9dbfcc6
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/c9dbfcc6
Branch: refs/heads/master
Commit: c9dbfcc653b868fdb28106c1d1bcb6cb6caac6cc
Parents: 5adec63
Author: Liang-Chi Hsieh <vi...@gmail.com>
Authored: Thu Dec 31 23:48:05 2015 -0800
Committer: Reynold Xin <rx...@databricks.com>
Committed: Thu Dec 31 23:48:05 2015 -0800
----------------------------------------------------------------------
.../sql/catalyst/encoders/RowEncoderSuite.scala | 15 ++-------------
1 file changed, 2 insertions(+), 13 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/c9dbfcc6/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/encoders/RowEncoderSuite.scala
----------------------------------------------------------------------
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 0ea51ec..8f4faab 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",
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org