Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/22749#discussion_r227682823
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/encoders/RowEncoder.scala
---
@@ -58,12 +58,10 @@ object RowEncoder {
def apply(schema: StructType): ExpressionEncoder[Row] = {
val cls = classOf[Row]
val inputObject = BoundReference(0, ObjectType(cls), nullable = true)
- val serializer = serializerFor(AssertNotNull(inputObject, Seq("top
level row object")), schema)
- val deserializer = deserializerFor(schema)
+ val serializer = serializerFor(inputObject, schema)
+ val deserializer = deserializerFor(GetColumnByOrdinal(0,
serializer.dataType), schema)
--- End diff --
ah i see, then let's leave it.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
