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