| 794 | } |
| 795 | |
| 796 | Result<int64_t> AsyncScanner::CountRows() { |
| 797 | return ::arrow::internal::RunSynchronously<Future<int64_t>>( |
| 798 | [this](Executor* executor) { return CountRowsAsync(executor); }, |
| 799 | scan_options_->use_threads); |
| 800 | } |
| 801 | |
| 802 | Result<std::shared_ptr<RecordBatchReader>> AsyncScanner::ToRecordBatchReader() { |
| 803 | ARROW_ASSIGN_OR_RAISE(auto it, ScanBatches()); |