Github user maropu commented on a diff in the pull request:
https://github.com/apache/spark/pull/20980#discussion_r182945511
--- Diff:
sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/ObjectExpressionsSuite.scala
---
@@ -415,6 +417,36 @@ class ObjectExpressionsSuite extends SparkFunSuite
with ExpressionEvalHelper {
}
}
}
+
+ private def javaSerializerFor(beanClass: Class[_])(inputObject:
Expression): CreateNamedStruct = {
+ JavaTypeInference.serializerFor(inputObject, TypeToken.of(beanClass))
match {
+ case e => CreateNamedStruct(Literal("value") :: e :: Nil)
+ }
+ }
+
+ test("SPARK-23589 ExternalMapToCatalyst should support interpreted
execution") {
--- End diff --
done
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
