| 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 |
nothing calls this directly
no test coverage detected