diff --git a/datafusion/core/src/physical_plan/file_format/parquet.rs b/datafusion/core/src/physical_plan/file_format/parquet.rs index 270271d43ebe..54701f82d44d 100644 --- a/datafusion/core/src/physical_plan/file_format/parquet.rs +++ b/datafusion/core/src/physical_plan/file_format/parquet.rs @@ -373,13 +373,13 @@ impl FileOpener for ParquetOpener { &self.metrics, ); - let reader = - BoxedAsyncFileReader(self.parquet_file_reader_factory.create_reader( + let reader: Box = + self.parquet_file_reader_factory.create_reader( self.partition_index, file_meta, self.metadata_size_hint, &self.metrics, - )?); + )?; let schema_adapter = SchemaAdapter::new(self.table_schema.clone()); let batch_size = self.batch_size; @@ -598,40 +598,6 @@ impl ParquetFileReaderFactory for DefaultParquetFileReaderFactory { } } -/// -/// BoxedAsyncFileReader has been created to satisfy type requirements of -/// parquet stream builder constructor. -/// -/// Temporary pending https://github.com/apache/arrow-rs/pull/2368 -struct BoxedAsyncFileReader(Box); - -impl AsyncFileReader for BoxedAsyncFileReader { - fn get_bytes( - &mut self, - range: Range, - ) -> BoxFuture<'_, ::parquet::errors::Result> { - self.0.get_bytes(range) - } - - fn get_byte_ranges( - &mut self, - ranges: Vec>, - ) -> BoxFuture<'_, parquet::errors::Result>> - // TODO: This where bound forces us to enable #![allow(where_clauses_object_safety)] (#3081) - // Upstream issue https://github.com/apache/arrow-rs/issues/2372 - where - Self: Send, - { - self.0.get_byte_ranges(ranges) - } - - fn get_metadata( - &mut self, - ) -> BoxFuture<'_, ::parquet::errors::Result>> { - self.0.get_metadata() - } -} - /// Wraps parquet statistics in a way /// that implements [`PruningStatistics`] struct RowGroupPruningStatistics<'a> {