Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/19598#discussion_r148936905
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/complexTypeExtractors.scala
---
@@ -186,6 +186,14 @@ case class GetArrayStructFields(
val values = ctx.freshName("values")
val j = ctx.freshName("j")
val row = ctx.freshName("row")
+ val nullSafeEval = if (field.nullable) {
+ s"""
+ if ($row.isNullAt($ordinal)) {
+ $values[$j] = null;
+ } else
+ """
+ } else ""
--- End diff --
Nit:
```Scala
} else {
""
}
```
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
