| 241 | return out; |
| 242 | } |
| 243 | arrow::Result<std::vector<std::shared_ptr<RecordBatch>>> ToRecordBatches() override { |
| 244 | return ToRecordBatches(stop_token_); |
| 245 | } |
| 246 | arrow::Result<std::vector<std::shared_ptr<RecordBatch>>> ToRecordBatches( |
| 247 | const StopToken& stop_token) override { |
| 248 | std::vector<std::shared_ptr<RecordBatch>> batches; |