| 1350 | } |
| 1351 | |
| 1352 | Status Finish(WriteStats* out_stats = nullptr) { |
| 1353 | RETURN_NOT_OK(writer_->Close()); |
| 1354 | if (out_stats) { |
| 1355 | *out_stats = writer_->stats(); |
| 1356 | } |
| 1357 | return sink_->Close(); |
| 1358 | } |
| 1359 | |
| 1360 | virtual Status ReadBatches(const IpcReadOptions& options, |
| 1361 | RecordBatchVector* out_batches, |