| 432 | } |
| 433 | |
| 434 | Future<> Finish() override { |
| 435 | dataset_writer_->Finish(); |
| 436 | // Some write tasks may still be in the queue at this point but that is ok. |
| 437 | return Future<>::MakeFinished(); |
| 438 | } |
| 439 | |
| 440 | private: |
| 441 | Status WriteNextBatch(std::shared_ptr<RecordBatch> batch, |