Add assert.

viirya · viirya · commit 51b76b163a95 · 2015-12-19T16:39:19.000+08:00
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/UserDefinedTypeSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/UserDefinedTypeSuite.scala
@@ -106,6 +106,9 @@ class UserDefinedTypeSuite extends QueryTest with SharedSQLContext with ParquetT
     val unsafeRows = points.map(pointEncoder.toRow(_).copy())
     val df = DataFrame(sqlContext, LocalRelation(attributeSeq, unsafeRows))
     val decodedPoints = df.collect()
+    points.zip(decodedPoints).foreach { case (p, p2) =>
+      assert(p.label == p2(0) && p.features == p2(1))
+    }
   }
 
   test("UDTs and UDFs") {

Original file line number	Diff line number	Diff line change
`@@ -106,6 +106,9 @@ class UserDefinedTypeSuite extends QueryTest with SharedSQLContext with ParquetT`
`106`	`106`	`val unsafeRows = points.map(pointEncoder.toRow(_).copy())`
`107`	`107`	`val df = DataFrame(sqlContext, LocalRelation(attributeSeq, unsafeRows))`
`108`	`108`	`val decodedPoints = df.collect()`
	`109`	`+ points.zip(decodedPoints).foreach { case (p, p2) =>`
	`110`	`+ assert(p.label == p2(0) && p.features == p2(1))`
	`111`	`+ }`
`109`	`112`	`}`
`110`	`113`
`111`	`114`	`test("UDTs and UDFs") {`