pitrou commented on code in PR #35874:
URL: https://github.com/apache/arrow/pull/35874#discussion_r1217627690
##########
cpp/src/arrow/acero/asof_join_node_test.cc:
##########
@@ -1360,6 +1361,102 @@ TRACED_TEST(AsofJoinTest, TestUnorderedOnKey, {
schema({field("time", int64()), field("key", int32()), field("r0_v0",
float64())}));
})
+struct BackpressureCounters {
+ int32_t pause_count = 0;
+ int32_t resume_count = 0;
Review Comment:
Should these be atomic? Presumably they can be updated from multiple threads.
--
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]
