Github user juliuszsompolski commented on a diff in the pull request:
https://github.com/apache/spark/pull/19324#discussion_r140528883
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/WholeStageCodegenExec.scala
---
@@ -329,6 +332,15 @@ case class WholeStageCodegenExec(child: SparkPlan)
extends UnaryExecNode with Co
def doCodeGen(): (CodegenContext, CodeAndComment) = {
val ctx = new CodegenContext
val code = child.asInstanceOf[CodegenSupport].produce(ctx, this)
+
+ // main next function.
+ ctx.addNewFunction("processNext",
--- End diff --
tangent fix: add processNext() as a separate function, so that it is also
taken into account by https://github.com/apache/spark/pull/18810
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
