We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4c83958 commit e82a35bCopy full SHA for e82a35b
1 file changed
cpp/src/arrow/acero/pipe_node.h
@@ -24,9 +24,9 @@
24
25
namespace arrow {
26
27
-using internal::checked_cast;
28
-
+using arrow::util::Mutex;
29
using compute::Ordering;
+using internal::checked_cast;
30
31
namespace acero {
32
class Pipe;
@@ -117,7 +117,7 @@ class ARROW_ACERO_EXPORT Pipe {
117
PipeSource* sync_node_{NULLPTR};
118
// backpressure
119
std::unordered_map<PipeSource*, SourceState> state_;
120
- util::Mutex mutex_;
+ Mutex mutex_;
121
std::atomic_size_t paused_count_{0};
122
std::unique_ptr<BackpressureControl> ctrl_;
123
// stopProducing
0 commit comments