| 502 | batch_writer_(std::move(writer)) {} |
| 503 | |
| 504 | Status CsvFileWriter::Write(const std::shared_ptr<RecordBatch>& batch) { |
| 505 | return batch_writer_->WriteRecordBatch(*batch); |
| 506 | } |
| 507 | |
| 508 | Future<> CsvFileWriter::FinishInternal() { |
| 509 | // The CSV writer's Close() is a no-op, so just treat it as synchronous |