Fix another issue.

viirya · viirya · commit fc9c1069d86b · 2016-06-21T15:42:49.000+08:00
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/encoders/RowEncoder.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/encoders/RowEncoder.scala
@@ -206,6 +206,7 @@ object RowEncoder {
     case _: ArrayType => ObjectType(classOf[scala.collection.Seq[_]])
     case _: MapType => ObjectType(classOf[scala.collection.Map[_, _]])
     case _: StructType => ObjectType(classOf[Row])
+    case p: PythonUserDefinedType => externalDataTypeFor(p.sqlType)
     case udt: UserDefinedType[_] => ObjectType(udt.userClass)
   }
 

Original file line number	Diff line number	Diff line change
`@@ -206,6 +206,7 @@ object RowEncoder {`
`206`	`206`	`case _: ArrayType => ObjectType(classOf[scala.collection.Seq[_]])`
`207`	`207`	`case _: MapType => ObjectType(classOf[scala.collection.Map[_, _]])`
`208`	`208`	`case _: StructType => ObjectType(classOf[Row])`
	`209`	`+ case p: PythonUserDefinedType => externalDataTypeFor(p.sqlType)`
`209`	`210`	`case udt: UserDefinedType[_] => ObjectType(udt.userClass)`
`210`	`211`	`}`
`211`	`212`