MCPcopy Create free account
hub / github.com/apache/arrow / DoFinish

Method DoFinish

cpp/src/arrow/acero/order_by_impl.cc:78–84  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

76 : SortBasicImpl(ctx, output_schema), options_(options) {}
77
78 Result<Datum> DoFinish() override {
79 std::unique_lock<std::mutex> lock(mutex_);
80 ARROW_ASSIGN_OR_RAISE(auto table,
81 Table::FromRecordBatches(output_schema_, std::move(batches_)));
82 ARROW_ASSIGN_OR_RAISE(auto indices, SelectKUnstable(table, options_, ctx_));
83 return Take(table, indices, TakeOptions::NoBoundsCheck(), ctx_);
84 }
85
86 std::string ToString() const override { return options_.ToString(); }
87

Callers

nothing calls this directly

Calls 2

TakeFunction · 0.85
NoBoundsCheckFunction · 0.85

Tested by

no test coverage detected