deps: bump arrow and parquet to 58.3.0 (#4346)

Author: mbutrovich

native/Cargo.lock

@@ -34,10 +34,10 @@ edition = "2021"
 rust-version = "1.88"
 
 [workspace.dependencies]
-arrow = { version = "58.2.0", features = ["prettyprint", "ffi", "chrono-tz"] }
+arrow = { version = "58.3.0", features = ["prettyprint", "ffi", "chrono-tz"] }
 async-trait = { version = "0.1" }
 bytes = { version = "1.11.1" }
-parquet = { version = "58.1.0", default-features = false, features = ["experimental"] }
+parquet = { version = "58.3.0", default-features = false, features = ["experimental"] }
 datafusion = { version = "53.1.0", default-features = false, features = ["unicode_expressions", "crypto_expressions", "nested_expressions", "parquet"] }
 datafusion-datasource = { version = "53.1.0" }
 datafusion-physical-expr-adapter = { version = "53.1.0" }

native/Cargo.toml

@@ -25,7 +25,7 @@ use parquet::{
     data_type::DataType,
     encodings::{
         encoding::{get_encoder, DictEncoder, Encoder},
-        levels::{max_buffer_size, LevelEncoder},
+        levels::LevelEncoder,
     },
     errors::Result,
     schema::types::ColumnDescPtr,
@@ -79,9 +79,8 @@ impl DataPageBuilderImpl {
         if max_level <= 0 {
             return 0;
         }
-        let size = max_buffer_size(Encoding::RLE, max_level, levels.len());
-        let mut level_encoder = LevelEncoder::v1(Encoding::RLE, max_level, size);
-        level_encoder.put(levels);
+        let mut level_encoder = LevelEncoder::v1_streaming(max_level);
+        level_encoder.put_with_observer(levels, |_, _| {});
         let encoded_levels = level_encoder.consume();
         // Actual encoded bytes (without length offset)
         let encoded_bytes = &encoded_levels[mem::size_of::<i32>()..];