| 1195 | } |
| 1196 | |
| 1197 | Status Finish(WriteStats* out_stats = nullptr) { |
| 1198 | RETURN_NOT_OK(writer_->Close()); |
| 1199 | if (out_stats) { |
| 1200 | *out_stats = writer_->stats(); |
| 1201 | } |
| 1202 | RETURN_NOT_OK(sink_->Close()); |
| 1203 | // Current offset into stream is the end of the file |
| 1204 | return sink_->Tell().Value(&footer_offset_); |
| 1205 | } |
| 1206 | |
| 1207 | virtual Status ReadBatches(const IpcReadOptions& options, |
| 1208 | RecordBatchVector* out_batches, |
no test coverage detected