From 23a9b51f6094d49711b51b0c31d639b06e10a844 Mon Sep 17 00:00:00 2001 From: Lachlan Deakin Date: Mon, 18 Mar 2024 07:52:33 +1100 Subject: [PATCH] Bump pcodec to 0.2.0 Bump pcodec to 0.2.0 Pump pcodec to 0.2.1 --- CHANGELOG.md | 1 + Cargo.toml | 2 +- src/array/codec/array_to_bytes/pcodec/pcodec_codec.rs | 2 +- .../codec/array_to_bytes/pcodec/pcodec_partial_decoder.rs | 7 ++++--- 4 files changed, 7 insertions(+), 5 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index 93aaf38e..36ceb0df 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -9,6 +9,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 ### Changed - **Breaking**: Bump MSRV to 1.73 (5 October, 2023) + - Bump `pco` (pcodec) to 0.2.1 ## [0.12.5] - 2024-03-17 diff --git a/Cargo.toml b/Cargo.toml index 0a2da293..263f849b 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -60,7 +60,7 @@ object_store = { version = "0.9.0", optional = true } opendal = { version = "0.45", optional = true } parking_lot = "0.12" pathdiff = "0.2" -pco = { version = "0.1.3", optional = true } +pco = { version = "0.2.1", optional = true } rayon = "1.6" rayon_iter_concurrent_limit = "0.2.0" reqwest = { version = "0.11", features = ["blocking"], optional = true } diff --git a/src/array/codec/array_to_bytes/pcodec/pcodec_codec.rs b/src/array/codec/array_to_bytes/pcodec/pcodec_codec.rs index 629ca994..5513488b 100644 --- a/src/array/codec/array_to_bytes/pcodec/pcodec_codec.rs +++ b/src/array/codec/array_to_bytes/pcodec/pcodec_codec.rs @@ -147,7 +147,7 @@ impl ArrayCodecTraits for PcodecCodec { let data_type = decoded_representation.data_type(); macro_rules! pcodec_decode { ( $t:ty ) => { - pco::standalone::auto_decompress(encoded_value.as_slice()) + pco::standalone::simple_decompress(encoded_value.as_slice()) .map(|bytes| transmute_to_bytes_vec::<$t>(bytes)) .map_err(|err| CodecError::Other(err.to_string())) }; diff --git a/src/array/codec/array_to_bytes/pcodec/pcodec_partial_decoder.rs b/src/array/codec/array_to_bytes/pcodec/pcodec_partial_decoder.rs index ab655663..199d8fa4 100644 --- a/src/array/codec/array_to_bytes/pcodec/pcodec_partial_decoder.rs +++ b/src/array/codec/array_to_bytes/pcodec/pcodec_partial_decoder.rs @@ -51,9 +51,10 @@ fn do_partial_decode( Some(decoded_value) => { macro_rules! pcodec_partial_decode { ( $t:ty ) => { - let decoded_chunk = pco::standalone::auto_decompress(decoded_value.as_slice()) - .map(|bytes| crate::array::transmute_to_bytes_vec::<$t>(bytes)) - .map_err(|err| CodecError::Other(err.to_string()))?; + let decoded_chunk = + pco::standalone::simple_decompress(decoded_value.as_slice()) + .map(|bytes| crate::array::transmute_to_bytes_vec::<$t>(bytes)) + .map_err(|err| CodecError::Other(err.to_string()))?; for array_subset in decoded_regions { let bytes_subset = array_subset .extract_bytes(