Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/19737#discussion_r152185474
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/GenerateUnsafeRowJoiner.scala
---
@@ -154,7 +164,10 @@ object GenerateUnsafeRowJoiner extends
CodeGenerator[(StructType, StructType), U
|$putLong(buf, $cursor, $getLong(buf, $cursor) + ($shift <<
32));
""".stripMargin
}
- }.mkString("\n")
+ }
+
+ val updateOffsets = ctx.splitExpressions(updateOffset,
"copyBitsetFunc",
+ ("long", "numBytesVariableRow1") :: Nil)
--- End diff --
The same here.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
