Github user ueshin commented on a diff in the pull request:
https://github.com/apache/spark/pull/21704#discussion_r202278265
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/TypeCoercion.scala
---
@@ -259,8 +270,22 @@ object TypeCoercion {
}
}
- private def haveSameType(exprs: Seq[Expression]): Boolean =
- exprs.map(_.dataType).distinct.length == 1
+ private def haveSameType(exprs: Seq[Expression]): Boolean = {
--- End diff --
Since we have `CreateMap`, we can't make all such expressions
`ComplexTypeMergingExpression`.
I'd apply 2) approach.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
