This is an automated email from the ASF dual-hosted git repository. etseidl pushed a commit to branch gh5854_thrift_remodel in repository https://gitbox.apache.org/repos/asf/arrow-rs.git
commit 0d2f33e5abe15960fded12a6433aeba45fae6ec8 Merge: a69c57834e f748db88f7 Author: Ed Seidl <[email protected]> AuthorDate: Mon Aug 11 15:11:18 2025 -0700 Merge remote-tracking branch 'origin/main' into gh5854_thrift_remodel .asf.yaml | 3 + .github/workflows/docs.yml | 2 +- .../src/builder/fixed_size_binary_builder.rs | 14 +- arrow-array/src/builder/generic_bytes_builder.rs | 46 +- arrow-array/src/builder/generic_list_builder.rs | 19 +- .../src/builder/generic_list_view_builder.rs | 23 +- arrow-array/src/builder/map_builder.rs | 14 +- arrow-array/src/builder/primitive_builder.rs | 34 +- arrow-array/src/ffi.rs | 2 +- arrow-avro/Cargo.toml | 13 +- arrow-avro/benches/decoder.rs | 559 +++++++++++++++ arrow-avro/src/codec.rs | 51 +- arrow-avro/src/reader/header.rs | 2 +- arrow-avro/src/reader/mod.rs | 539 ++++++++++++--- arrow-buffer/src/buffer/boolean.rs | 2 +- arrow-buffer/src/buffer/immutable.rs | 2 +- arrow-cast/src/pretty.rs | 7 +- arrow-data/src/transform/boolean.rs | 2 +- arrow-data/src/transform/fixed_binary.rs | 2 +- arrow-data/src/transform/fixed_size_list.rs | 2 +- arrow-data/src/transform/list.rs | 4 +- arrow-data/src/transform/mod.rs | 8 +- arrow-data/src/transform/null.rs | 2 +- arrow-data/src/transform/primitive.rs | 4 +- arrow-data/src/transform/run.rs | 2 +- arrow-data/src/transform/structure.rs | 2 +- arrow-data/src/transform/union.rs | 4 +- arrow-data/src/transform/variable_size.rs | 2 +- arrow-flight/src/sql/metadata/sql_info.rs | 2 +- arrow-flight/src/sql/metadata/xdbc_info.rs | 2 +- arrow-ipc/src/lib.rs | 1 + arrow-ipc/src/reader.rs | 56 +- arrow-ord/src/sort.rs | 381 ++++++++++- arrow-row/src/lib.rs | 10 +- arrow-select/src/concat.rs | 24 +- arrow/examples/dynamic_types.rs | 2 +- parquet-variant-compute/Cargo.toml | 2 +- parquet-variant-compute/src/cast_to_variant.rs | 162 ++++- parquet-variant-compute/src/from_json.rs | 6 +- parquet-variant-compute/src/lib.rs | 22 +- parquet-variant-compute/src/variant_array.rs | 317 +++++++-- .../src/variant_array_builder.rs | 8 +- parquet-variant-compute/src/variant_get.rs | 180 ----- parquet-variant-compute/src/variant_get/mod.rs | 430 ++++++++++++ .../src/variant_get/output/mod.rs | 87 +++ .../src/variant_get/output/primitive.rs | 166 +++++ .../src/variant_get/output/variant.rs | 146 ++++ parquet-variant-json/src/from_json.rs | 4 +- parquet-variant/src/builder.rs | 24 +- parquet-variant/src/decoder.rs | 5 +- parquet-variant/src/path.rs | 4 +- parquet-variant/src/variant.rs | 4 +- parquet/src/arrow/array_reader/builder.rs | 94 ++- .../src/arrow/array_reader/cached_array_reader.rs | 762 +++++++++++++++++++++ parquet/src/arrow/array_reader/list_array.rs | 4 +- parquet/src/arrow/array_reader/mod.rs | 5 +- parquet/src/arrow/array_reader/row_group_cache.rs | 206 ++++++ parquet/src/arrow/arrow_reader/metrics.rs | 135 ++++ parquet/src/arrow/arrow_reader/mod.rs | 117 +++- parquet/src/arrow/arrow_reader/selection.rs | 53 ++ parquet/src/arrow/arrow_writer/mod.rs | 89 ++- parquet/src/arrow/async_reader/mod.rs | 234 ++++++- parquet/src/arrow/async_writer/mod.rs | 44 -- parquet/src/arrow/mod.rs | 7 + parquet/src/encryption/decrypt.rs | 4 +- parquet/src/file/properties.rs | 8 +- parquet/src/file/reader.rs | 4 +- parquet/src/file/serialized_reader.rs | 4 +- parquet/src/file/writer.rs | 2 +- parquet/src/record/api.rs | 2 +- parquet/src/schema/types.rs | 7 +- parquet/tests/arrow_reader/mod.rs | 2 + parquet/tests/arrow_reader/predicate_cache.rs | 279 ++++++++ parquet/tests/encryption/encryption.rs | 68 +- parquet/tests/encryption/encryption_async.rs | 110 ++- parquet/tests/encryption/encryption_util.rs | 153 ++++- 76 files changed, 5109 insertions(+), 695 deletions(-) diff --cc parquet/src/arrow/arrow_reader/mod.rs index a934a93ef2,3d20fa0a22..4af8f76940 --- a/parquet/src/arrow/arrow_reader/mod.rs +++ b/parquet/src/arrow/arrow_reader/mod.rs @@@ -40,8 -39,10 +40,9 @@@ use crate::encryption::decrypt::FileDec use crate::errors::{ParquetError, Result}; use crate::file::metadata::{ParquetMetaData, ParquetMetaDataReader}; use crate::file::reader::{ChunkReader, SerializedPageReader}; -use crate::format::{BloomFilterAlgorithm, BloomFilterCompression, BloomFilterHash}; use crate::schema::types::SchemaDescriptor; + use crate::arrow::arrow_reader::metrics::ArrowReaderMetrics; pub(crate) use read_plan::{ReadPlan, ReadPlanBuilder}; mod filter;
