Skip to content

Commit 674b669

Browse files
author
Rafał Hibner
committed
Propagate ordering through pipe_tee
1 parent 71110db commit 674b669

1 file changed

Lines changed: 2 additions & 0 deletions

File tree

cpp/src/arrow/acero/pipe_node.cc

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -196,6 +196,8 @@ class PipeTeeNode : public PipeSource, public PipeSinkNode {
196196
static const char kKindName[];
197197
const char* kind_name() const override { return kKindName; }
198198

199+
const Ordering& ordering() const override { return inputs_[0]->ordering(); }
200+
199201
Status StartProducing() override {
200202
auto st = PipeSource::Validate(ordering());
201203
if (!st.ok()) {

0 commit comments

Comments
 (0)