diff --git a/parquet/src/arrow/async_reader.rs b/parquet/src/arrow/async_reader.rs index 640d1b81f82..ce9bfd37da9 100644 --- a/parquet/src/arrow/async_reader.rs +++ b/parquet/src/arrow/async_reader.rs @@ -108,7 +108,7 @@ use crate::file::FOOTER_SIZE; use crate::schema::types::{ColumnDescPtr, SchemaDescPtr, SchemaDescriptor}; /// The asynchronous interface used by [`ParquetRecordBatchStream`] to read parquet files -pub trait AsyncFileReader { +pub trait AsyncFileReader: Send { /// Retrieve the bytes in `range` fn get_bytes(&mut self, range: Range) -> BoxFuture<'_, Result>; @@ -116,10 +116,7 @@ pub trait AsyncFileReader { fn get_byte_ranges( &mut self, ranges: Vec>, - ) -> BoxFuture<'_, Result>> - where - Self: Send, - { + ) -> BoxFuture<'_, Result>> { async move { let mut result = Vec::with_capacity(ranges.len());