| 451 | } // namespace |
| 452 | |
| 453 | Future<std::shared_ptr<InspectedFragment>> CsvFileFormat::InspectFragment( |
| 454 | const FileSource& source, const FragmentScanOptions* format_options, |
| 455 | compute::ExecContext* exec_context) const { |
| 456 | auto csv_options = static_cast<const CsvFragmentScanOptions*>(format_options); |
| 457 | Executor* io_executor; |
| 458 | if (source.filesystem()) { |
| 459 | io_executor = source.filesystem()->io_context().executor(); |
| 460 | } else { |
| 461 | io_executor = exec_context->executor(); |
| 462 | } |
| 463 | return DeferNotOk(io_executor->Submit([source, csv_options, exec_context]() { |
| 464 | return DoInspectFragment(source, *csv_options, exec_context); |
| 465 | })); |
| 466 | } |
| 467 | |
| 468 | // |
| 469 | // CsvFileWriter, CsvFileWriteOptions |
nothing calls this directly
no test coverage detected