| 406 | } |
| 407 | |
| 408 | Result<EnumeratedRecordBatchGenerator> AsyncScanner::ScanBatchesUnorderedAsync() { |
| 409 | return ScanBatchesUnorderedAsync(scan_options_->cpu_executor |
| 410 | ? scan_options_->cpu_executor |
| 411 | : ::arrow::internal::GetCpuThreadPool(), |
| 412 | /*sequence_fragments=*/false); |
| 413 | } |
| 414 | |
| 415 | Result<EnumeratedRecordBatchGenerator> AsyncScanner::ScanBatchesUnorderedAsync( |
| 416 | ::arrow::internal::Executor* cpu_thread_pool) { |