Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/19811#discussion_r157110169
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateMutableProjection.scala
---
@@ -57,41 +57,37 @@ object GenerateMutableProjection extends
CodeGenerator[Seq[Expression], MutableP
case _ => true
}.unzip
val exprVals = ctx.generateExpressions(validExpr,
useSubexprElimination)
- val projectionCodes = exprVals.zip(index).map {
+
+ // 4-tuples: (code for projection, isNull variable name, value
variable name, column index)
+ val projectionCodes: Seq[(String, String, String, Int)] =
exprVals.zip(index).map {
--- End diff --
Why needs to return column index?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
