address comments

cloud-fan · cloud-fan · commit 6b2641fc5e66 · 2016-06-03T10:34:19.000-07:00
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/encoders/ExpressionEncoder.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/encoders/ExpressionEncoder.scala
@@ -55,7 +55,7 @@ object ExpressionEncoder {
       inputObject
     } else {
       // For input object of non-flat type, we can't encode it to row if it's null, as Spark SQL
-      // doesn't allow row to be null, only its columns can be null.
+      // doesn't allow top-level row to be null, only its columns can be null.
       AssertNotNull(inputObject, Seq("top level non-flat input object"))
     }
     val serializer = ScalaReflection.serializerFor[T](nullSafeInput)

Original file line number	Diff line number	Diff line change
`@@ -55,7 +55,7 @@ object ExpressionEncoder {`
`55`	`55`	`inputObject`
`56`	`56`	`} else {`
`57`	`57`	`// For input object of non-flat type, we can't encode it to row if it's null, as Spark SQL`
`58`		`- // doesn't allow row to be null, only its columns can be null.`
	`58`	`+ // doesn't allow top-level row to be null, only its columns can be null.`
`59`	`59`	`AssertNotNull(inputObject, Seq("top level non-flat input object"))`
`60`	`60`	`}`
`61`	`61`	`val serializer = ScalaReflection.serializerFor[T](nullSafeInput)`