We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0689cbc commit ba14f4cCopy full SHA for ba14f4c
cpp/src/arrow/acero/backpressure.cc
@@ -19,6 +19,7 @@
19
#include "arrow/acero/exec_plan.h"
20
21
namespace arrow::acero {
22
+
23
BackpressureController::BackpressureController(ExecNode* node, ExecNode* output,
24
std::atomic<int32_t>& backpressure_counter)
25
: node_(node), output_(output), backpressure_counter_(backpressure_counter) {}
0 commit comments