| 771 | parquet_writer_(std::move(writer)) {} |
| 772 | |
| 773 | Status ParquetFileWriter::Write(const std::shared_ptr<RecordBatch>& batch) { |
| 774 | ARROW_ASSIGN_OR_RAISE(auto table, Table::FromRecordBatches(batch->schema(), {batch})); |
| 775 | return parquet_writer_->WriteTable(*table, batch->num_rows()); |
| 776 | } |
| 777 | |
| 778 | Future<> ParquetFileWriter::FinishInternal() { |
| 779 | return DeferNotOk(destination_locator_.filesystem->io_context().executor()->Submit( |
nothing calls this directly
no test coverage detected