| 1847 | } |
| 1848 | |
| 1849 | Status WriteBatchPayload(const RecordBatch& batch) { |
| 1850 | // write record batch payload only |
| 1851 | IpcPayload payload; |
| 1852 | RETURN_NOT_OK(GetRecordBatchPayload(batch, IpcWriteOptions::Defaults(), &payload)); |
| 1853 | return payload_writer_->WritePayload(payload); |
| 1854 | } |
| 1855 | |
| 1856 | Status Close() { |
| 1857 | RETURN_NOT_OK(payload_writer_->Close()); |
no test coverage detected