afterincomparableyum commented on code in PR #7124:
URL: https://github.com/apache/datafusion-comet/pull/7124#discussion_r4396966672
##########
spark/src/main/scala/org/apache/spark/sql/comet/CometMapInBatchExec.scala:
##########
@@ -106,8 +106,9 @@ case class CometMapInBatchExec(
columnarBatchIter.map { batch =>
// Python returns a single struct column; flatten to the user's output
columns. The runner
// produces Comet vectors, so the struct's children are already
CometVectors that downstream
- // consumers (a stacked CometMapInBatchExec, or NativeUtil.exportBatch
for a native Comet
- // operator) can use directly.
+ // consumers (a stacked CometMapInBatchExec, the Arrow C Stream in
CometNativeArrowSource for
Review Comment:
Thank you, rewrapped. @andygrove the next commit will resolve all the CI
failures you see.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]