westonpace commented on code in PR #15253:
URL: https://github.com/apache/arrow/pull/15253#discussion_r1067567073
##########
cpp/src/arrow/compute/exec/map_node.cc:
##########
@@ -36,22 +36,16 @@ namespace compute {
MapNode::MapNode(ExecPlan* plan, std::vector<ExecNode*> inputs,
Review Comment:
I poked at that a little. I think it still serves some benefit:
* Forwards backpressure
* Forwards guarantees (and soon, batch index)
* Uses an AtomicCounter to trigger an optional finish signal when all
processing is done (used by the tee node)
I think this justifies its existence.
--
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]
