| 1765 | } |
| 1766 | |
| 1767 | Result<const flatbuf::Message*> GetFlatbufMessage( |
| 1768 | const std::shared_ptr<Message>& message) { |
| 1769 | const Buffer& metadata = *message->metadata(); |
| 1770 | const flatbuf::Message* flatbuf_message = nullptr; |
| 1771 | RETURN_NOT_OK( |
| 1772 | internal::VerifyMessage(metadata.data(), metadata.size(), &flatbuf_message)); |
| 1773 | return flatbuf_message; |
| 1774 | } |
| 1775 | |
| 1776 | struct CachedRecordBatchReadContext { |
| 1777 | CachedRecordBatchReadContext(std::shared_ptr<Schema> sch, |
nothing calls this directly
no test coverage detected