Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/19598#discussion_r148931429
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/complexTypeExtractors.scala
---
@@ -309,6 +312,8 @@ case class GetMapValue(child: Expression, key:
Expression)
val found = ctx.freshName("found")
val key = ctx.freshName("key")
val values = ctx.freshName("values")
+ val nullCheck = if
(!child.dataType.asInstanceOf[MapType].valueContainsNull) ""
+ else s" || $values.isNullAt($index)"
--- End diff --
ditto
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
