| 800 | } |
| 801 | |
| 802 | Result<std::shared_ptr<RecordBatchReader>> AsyncScanner::ToRecordBatchReader() { |
| 803 | ARROW_ASSIGN_OR_RAISE(auto it, ScanBatches()); |
| 804 | return std::make_shared<ScannerRecordBatchReader>(options()->projected_schema, |
| 805 | std::move(it)); |
| 806 | } |
| 807 | |
| 808 | const std::shared_ptr<Dataset>& AsyncScanner::dataset() const { return dataset_; } |
| 809 | } // namespace |