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