| 1778 | } |
| 1779 | |
| 1780 | Result<const flatbuf::Message*> GetFlatbufMessage( |
| 1781 | const std::shared_ptr<Message>& message) { |
| 1782 | const Buffer& metadata = *message->metadata(); |
| 1783 | const flatbuf::Message* flatbuf_message = nullptr; |
| 1784 | RETURN_NOT_OK( |
| 1785 | internal::VerifyMessage(metadata.data(), metadata.size(), &flatbuf_message)); |
| 1786 | return flatbuf_message; |
| 1787 | } |
| 1788 | |
| 1789 | struct CachedRecordBatchReadContext { |
| 1790 | CachedRecordBatchReadContext(std::shared_ptr<Schema> sch, |
nothing calls this directly
no test coverage detected