Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/19598#discussion_r148936939
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/complexTypeExtractors.scala
---
@@ -309,6 +318,9 @@ 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) {
+ s" || $values.isNullAt($index)"
+ } else ""
--- End diff --
The same here
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
