From 9b41f01d139cf10102962adf94935b5a7da94b06 Mon Sep 17 00:00:00 2001 From: Raphael Taylor-Davies Date: Mon, 8 Aug 2022 16:09:04 +0100 Subject: [PATCH 1/2] Remove get_byte_ranges where bound --- parquet/src/arrow/async_reader.rs | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/parquet/src/arrow/async_reader.rs b/parquet/src/arrow/async_reader.rs index 640d1b81f82..477a6031cc9 100644 --- a/parquet/src/arrow/async_reader.rs +++ b/parquet/src/arrow/async_reader.rs @@ -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()); From a62cc4ccf9fea0b0036bd3195d59a8f420bb385d Mon Sep 17 00:00:00 2001 From: Raphael Taylor-Davies Date: Mon, 8 Aug 2022 16:15:14 +0100 Subject: [PATCH 2/2] Add Send bound --- parquet/src/arrow/async_reader.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parquet/src/arrow/async_reader.rs b/parquet/src/arrow/async_reader.rs index 477a6031cc9..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>;