Bump pcodec to 0.2.0

Bump pcodec to 0.2.0 Pump pcodec to 0.2.1
LDeakin · Mar 21, 2024 · 23a9b51 · 23a9b51
1 parent 37149b2
commit 23a9b51
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 5 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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(