chore(deps): bump arrow/parquet to 57 (#259)

Set workspace version to 0.6.0 for the dependency major update.

Update parquet footer parsing/metadata imports and default manifest executor in std-only builds.

Author: belveryin

Cargo.toml

@@ -15,17 +15,17 @@ resolver = "2"
 edition = "2021"
 license = "Apache-2.0"
 repository = "https://github.com/tonbo-io/fusio"
-version = "0.5.0"
+version = "0.6.0"
 
 [workspace.dependencies]
 # Internal crates
-fusio = { version = "0.5.0", path = "fusio", default-features = false }
-fusio-core = { version = "0.5.0", path = "fusio-core" }
-fusio-opendal = { version = "0.5.0", path = "fusio-opendal" }
-fusio-parquet = { version = "0.5.0", path = "fusio-parquet" }
+fusio = { version = "0.6.0", path = "fusio", default-features = false }
+fusio-core = { version = "0.6.0", path = "fusio-core" }
+fusio-opendal = { version = "0.6.0", path = "fusio-opendal" }
+fusio-parquet = { version = "0.6.0", path = "fusio-parquet" }
 
 # External dependencies
-arrow = { version = "56" }
+arrow = { version = "57" }
 async-stream = { version = "0.3" }
 bytes = { version = "1.7", default-features = false }
 cfg-if = { version = "1.0.0" }
@@ -39,7 +39,7 @@ js-sys = { version = "0.3.72" }
 monoio = { version = "0.2" }
 object_store = { version = "0.12" }
 opendal = { version = "0.50.1", default-features = false }
-parquet = { version = "56", default-features = false }
+parquet = { version = "57", default-features = false }
 rand = { version = "0.8" }
 serde = { version = "1", features = ["derive"] }
 serde_json = { version = "1" }

fusio-manifest/src/lib.rs

@@ -31,7 +31,6 @@ pub use context::ManifestContext;
 pub use fusio::executor::tokio::TokioExecutor;
 #[cfg(all(feature = "web", target_arch = "wasm32"))]
 pub use fusio::executor::web::WebExecutor;
-#[cfg(feature = "tokio")]
 pub use fusio::executor::NoopExecutor;
 
 /// Default executor type based on enabled features.
@@ -43,6 +42,13 @@ pub type DefaultExecutor = TokioExecutor;
 #[cfg(all(feature = "web", target_arch = "wasm32", not(feature = "tokio")))]
 pub type DefaultExecutor = WebExecutor;
 
+#[cfg(all(
+    feature = "std",
+    not(feature = "tokio"),
+    not(all(feature = "web", target_arch = "wasm32"))
+))]
+pub type DefaultExecutor = NoopExecutor;
+
 pub(crate) mod cache;
 pub mod retention;
 pub(crate) mod segment;

fusio-parquet/src/reader.rs

@@ -14,7 +14,7 @@ use parquet::{
     },
     errors::ParquetError,
     file::{
-        metadata::{PageIndexPolicy, ParquetMetaData, ParquetMetaDataReader},
+        metadata::{FooterTail, PageIndexPolicy, ParquetMetaData, ParquetMetaDataReader},
         FOOTER_SIZE,
     },
 };
@@ -81,11 +81,7 @@ impl<E: Executor> AsyncReader<E> {
             let buf = &prefetched_footer_slice
                 [(prefetched_footer_length - FOOTER_SIZE)..prefetched_footer_length];
             debug_assert!(buf.len() == FOOTER_SIZE);
-            ParquetMetaDataReader::decode_footer_tail(
-                buf.try_into()
-                    .expect("it must convert footer buffer to fixed-size array"),
-            )?
-            .metadata_length()
+            FooterTail::try_from(buf)?.metadata_length()
         };
 
         if prefetched_footer_length >= metadata_length + FOOTER_SIZE {
@@ -200,8 +196,7 @@ mod tests {
     use futures::StreamExt;
     use parquet::{
         arrow::{AsyncArrowWriter, ParquetRecordBatchStreamBuilder},
-        file::properties::WriterProperties,
-        format::KeyValue,
+        file::{metadata::KeyValue, properties::WriterProperties},
     };
     use rand::{distributions::Alphanumeric, Rng};
     use tempfile::tempdir;