| 1739 | } |
| 1740 | |
| 1741 | Result<IpcReadContext> GetIpcReadContext(const flatbuf::Message* message, |
| 1742 | const flatbuf::RecordBatch* batch) { |
| 1743 | IpcReadContext context(&dictionary_memo_, options_, swap_endian_); |
| 1744 | Compression::type compression; |
| 1745 | RETURN_NOT_OK(GetCompression(batch, &compression)); |
| 1746 | if (context.compression == Compression::UNCOMPRESSED && |
| 1747 | message->version() == flatbuf::MetadataVersion::MetadataVersion_V4) { |
| 1748 | // Possibly obtain codec information from experimental serialization format |
| 1749 | // in 0.17.x |
| 1750 | RETURN_NOT_OK(GetCompressionExperimental(message, &compression)); |
| 1751 | } |
| 1752 | context.compression = compression; |
| 1753 | context.metadata_version = internal::GetMetadataVersion(message->version()); |
| 1754 | return context; |
| 1755 | } |
| 1756 | |
| 1757 | Result<const flatbuf::RecordBatch*> GetBatchFromMessage( |
| 1758 | const flatbuf::Message* message) { |
nothing calls this directly
no test coverage detected