Skip to content

Commit 167c059

Browse files
committed
Merge branch 'SequencingQueue' into combined
2 parents bd63e47 + c05809e commit 167c059

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

cpp/src/arrow/acero/accumulation_queue.h

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
#include <optional>
2323
#include <vector>
2424

25+
#include "arrow/acero/visibility.h"
2526
#include "arrow/compute/exec.h"
2627
#include "arrow/result.h"
2728

@@ -70,7 +71,7 @@ class AccumulationQueue {
7071
/// For example, in a top-n node, the process callback should determine how many
7172
/// rows need to be delivered for the given batch, and then return a task to actually
7273
/// deliver those rows.
73-
class SequencingQueue {
74+
class ARROW_ACERO_EXPORT SequencingQueue {
7475
public:
7576
using Task = std::function<Status()>;
7677

@@ -123,7 +124,7 @@ class SequencingQueue {
123124
///
124125
/// It can be helpful to think of this as if a dedicated thread is running Process as
125126
/// batches arrive
126-
class SerialSequencingQueue {
127+
class ARROW_ACERO_EXPORT SerialSequencingQueue {
127128
public:
128129
/// Strategy that describes how to handle items
129130
class Processor {

0 commit comments

Comments
 (0)