| 1854 | } |
| 1855 | |
| 1856 | Status Close() { |
| 1857 | RETURN_NOT_OK(payload_writer_->Close()); |
| 1858 | return sink_->Close(); |
| 1859 | } |
| 1860 | |
| 1861 | Status ReadBatch(std::shared_ptr<RecordBatch>* out_batch) { |
| 1862 | auto buf_reader = std::make_shared<io::BufferReader>(buffer_); |
no outgoing calls
no test coverage detected