| 1752 | } |
| 1753 | |
| 1754 | Result<IpcReadContext> GetIpcReadContext(const flatbuf::Message* message, |
| 1755 | const flatbuf::RecordBatch* batch) { |
| 1756 | IpcReadContext context(&dictionary_memo_, options_, swap_endian_); |
| 1757 | Compression::type compression; |
| 1758 | RETURN_NOT_OK(GetCompression(batch, &compression)); |
| 1759 | if (context.compression == Compression::UNCOMPRESSED && |
| 1760 | message->version() == flatbuf::MetadataVersion::MetadataVersion_V4) { |
| 1761 | // Possibly obtain codec information from experimental serialization format |
| 1762 | // in 0.17.x |
| 1763 | RETURN_NOT_OK(GetCompressionExperimental(message, &compression)); |
| 1764 | } |
| 1765 | context.compression = compression; |
| 1766 | context.metadata_version = internal::GetMetadataVersion(message->version()); |
| 1767 | return context; |
| 1768 | } |
| 1769 | |
| 1770 | Result<const flatbuf::RecordBatch*> GetBatchFromMessage( |
| 1771 | const flatbuf::Message* message) { |
nothing calls this directly
no test coverage detected