From 28021a44c3950228b856d3c7e9067a70c8847e34 Mon Sep 17 00:00:00 2001 From: Scott Donnelly Date: Thu, 10 Oct 2024 19:02:39 +0100 Subject: [PATCH] chore: roll back previous commit and fix import order --- Cargo.toml | 14 +++++++------- crates/iceberg/src/arrow/reader.rs | 2 +- 2 files changed, 8 insertions(+), 8 deletions(-) diff --git a/Cargo.toml b/Cargo.toml index ae4e3ade5..82f98103e 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -39,12 +39,12 @@ rust-version = "1.77.1" anyhow = "1.0.72" apache-avro = "0.17" array-init = "2" -arrow-arith = { version = "53.0" } -arrow-array = { version = "53.0" } -arrow-ord = { version = "53.0" } -arrow-schema = { version = "53.0" } -arrow-select = { version = "53.0" } -arrow-string = { version = "53.0" } +arrow-arith = { version = "53" } +arrow-array = { version = "53" } +arrow-ord = { version = "53" } +arrow-schema = { version = "53" } +arrow-select = { version = "53" } +arrow-string = { version = "53" } async-stream = "0.3.5" async-trait = "0.1" async-std = "1.12" @@ -72,7 +72,7 @@ murmur3 = "0.5.2" once_cell = "1" opendal = "0.50" ordered-float = "4" -parquet = "53.0" +parquet = "53" paste = "1" pilota = "0.11.2" pretty_assertions = "1.4" diff --git a/crates/iceberg/src/arrow/reader.rs b/crates/iceberg/src/arrow/reader.rs index 7a96f3aed..0cb74bcfd 100644 --- a/crates/iceberg/src/arrow/reader.rs +++ b/crates/iceberg/src/arrow/reader.rs @@ -32,10 +32,10 @@ use fnv::FnvHashSet; use futures::channel::mpsc::{channel, Sender}; use futures::future::BoxFuture; use futures::{try_join, FutureExt, SinkExt, StreamExt, TryFutureExt, TryStreamExt}; -use parquet::arrow::async_reader::AsyncFileReader; use parquet::arrow::arrow_reader::{ ArrowPredicateFn, ArrowReaderOptions, RowFilter, RowSelection, RowSelector, }; +use parquet::arrow::async_reader::AsyncFileReader; use parquet::arrow::{ParquetRecordBatchStreamBuilder, ProjectionMask, PARQUET_FIELD_ID_META_KEY}; use parquet::file::metadata::{ParquetMetaData, ParquetMetaDataReader}; use parquet::schema::types::{SchemaDescriptor, Type as ParquetType};