Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/21352#discussion_r203058283
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/collectionOperations.scala
---
@@ -2109,7 +2107,7 @@ case class ElementAt(left: Expression, right:
Expression) extends GetMapValueUti
Seq(TypeCollection(ArrayType, MapType),
left.dataType match {
case _: ArrayType => IntegerType
- case _: MapType => left.dataType.asInstanceOf[MapType].keyType
--- End diff --
why change this?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
