| 381 | } |
| 382 | |
| 383 | Result<RecordBatchGenerator> CsvFileFormat::ScanBatchesAsync( |
| 384 | const std::shared_ptr<ScanOptions>& scan_options, |
| 385 | const std::shared_ptr<FileFragment>& file) const { |
| 386 | auto this_ = checked_pointer_cast<const CsvFileFormat>(shared_from_this()); |
| 387 | auto source = file->source(); |
| 388 | auto reader_fut = |
| 389 | OpenReaderAsync(source, *this, scan_options, ::arrow::internal::GetCpuThreadPool()); |
| 390 | auto generator = GeneratorFromReader(std::move(reader_fut), scan_options->batch_size); |
| 391 | WRAP_ASYNC_GENERATOR_WITH_CHILD_SPAN( |
| 392 | generator, "arrow::dataset::CsvFileFormat::ScanBatchesAsync::Next"); |
| 393 | return generator; |
| 394 | } |
| 395 | |
| 396 | Future<std::optional<int64_t>> CsvFileFormat::CountRows( |
| 397 | const std::shared_ptr<FileFragment>& file, compute::Expression predicate, |
nothing calls this directly
no test coverage detected