westonpace commented on code in PR #34392:
URL: https://github.com/apache/arrow/pull/34392#discussion_r1187934097
##########
cpp/src/arrow/acero/asof_join_node.cc:
##########
@@ -200,8 +207,74 @@ class ConcurrentQueue {
std::condition_variable cond_;
};
+class AsofJoinNode;
+
+#ifndef NDEBUG
+// Get the debug-stream associated with the as-of-join node
+std::ostream* GetDebugStream(AsofJoinNode& node);
+
+// Get the debug-mutex associated with the as-of-join node
+std::mutex* GetDebugMutex(AsofJoinNode& node);
+
+// A debug-facility that wraps output-stream insertions with synchronization.
Code like
+//
+// DebugSync(as_of_join_node) << ... << ... << ... ;
+//
+// will insert to the node's debug-stream and guard all insertions as one
operation using
+// the node's debug-mutex.
+class DebugSync {
Review Comment:
Yes. I would be ok with that. As long as an issue is created first and
there is a plan to get to it.
--
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]
