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