Skip to content

Commit

Permalink
Export SequencingQueue and SerialSequencingQueue
Browse files Browse the repository at this point in the history
  • Loading branch information
mroz45 committed Jan 9, 2025
1 parent 2b5f56c commit c05809e
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions cpp/src/arrow/acero/accumulation_queue.h
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@
#include <optional>
#include <vector>

#include "arrow/acero/visibility.h"
#include "arrow/compute/exec.h"
#include "arrow/result.h"

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

Expand Down Expand Up @@ -123,7 +124,7 @@ class SequencingQueue {
///
/// It can be helpful to think of this as if a dedicated thread is running Process as
/// batches arrive
class SerialSequencingQueue {
class ARROW_ACERO_EXPORT SerialSequencingQueue {
public:
/// Strategy that describes how to handle items
class Processor {
Expand Down

0 comments on commit c05809e

Please sign in to comment.