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