| 1859 | } |
| 1860 | |
| 1861 | Status ReadBatch(std::shared_ptr<RecordBatch>* out_batch) { |
| 1862 | auto buf_reader = std::make_shared<io::BufferReader>(buffer_); |
| 1863 | std::shared_ptr<RecordBatchReader> reader; |
| 1864 | ARROW_ASSIGN_OR_RAISE( |
| 1865 | reader, RecordBatchStreamReader::Open(buf_reader, IpcReadOptions::Defaults())) |
| 1866 | return reader->ReadNext(out_batch); |
| 1867 | } |
| 1868 | |
| 1869 | std::unique_ptr<internal::IpcPayloadWriter> payload_writer_; |
| 1870 | const Schema& schema_; |
no test coverage detected