| 609 | } |
| 610 | |
| 611 | Result<TaggedRecordBatchGenerator> AsyncScanner::ScanBatchesAsync() { |
| 612 | return ScanBatchesAsync(scan_options_->cpu_executor |
| 613 | ? scan_options_->cpu_executor |
| 614 | : ::arrow::internal::GetCpuThreadPool()); |
| 615 | } |
| 616 | |
| 617 | Result<TaggedRecordBatchGenerator> AsyncScanner::ScanBatchesAsync( |
| 618 | Executor* cpu_executor) { |