From 8969b5520c3a56a0774c83061eae733f010adb61 Mon Sep 17 00:00:00 2001 From: Andrew Lamb Date: Tue, 11 Jun 2024 11:57:01 -0400 Subject: [PATCH] Revert unecessary changes --- datafusion/core/src/datasource/physical_plan/mod.rs | 2 +- datafusion/core/src/datasource/physical_plan/parquet/mod.rs | 2 +- .../core/src/datasource/physical_plan/parquet/opener.rs | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/datafusion/core/src/datasource/physical_plan/mod.rs b/datafusion/core/src/datasource/physical_plan/mod.rs index db63b27565b7..720e29e35582 100644 --- a/datafusion/core/src/datasource/physical_plan/mod.rs +++ b/datafusion/core/src/datasource/physical_plan/mod.rs @@ -31,7 +31,7 @@ mod statistics; pub(crate) use self::csv::plan_to_csv; pub(crate) use self::json::plan_to_json; #[cfg(feature = "parquet")] -pub use self::parquet::{ParquetExec, ParquetFileMetrics}; +pub use self::parquet::{ParquetExec, ParquetFileMetrics, ParquetFileReaderFactory}; pub use arrow_file::ArrowExec; pub use avro::AvroExec; diff --git a/datafusion/core/src/datasource/physical_plan/parquet/mod.rs b/datafusion/core/src/datasource/physical_plan/parquet/mod.rs index a849560d83ef..bf8b717aecdb 100644 --- a/datafusion/core/src/datasource/physical_plan/parquet/mod.rs +++ b/datafusion/core/src/datasource/physical_plan/parquet/mod.rs @@ -57,12 +57,12 @@ mod row_groups; mod statistics; mod writer; -use crate::datasource::physical_plan::parquet::opener::ParquetOpener; use crate::datasource::schema_adapter::{ DefaultSchemaAdapterFactory, SchemaAdapterFactory, }; pub use access_plan::{ParquetAccessPlan, RowGroupAccess}; pub use metrics::ParquetFileMetrics; +use opener::ParquetOpener; pub use reader::{DefaultParquetFileReaderFactory, ParquetFileReaderFactory}; pub use statistics::StatisticsConverter; pub use writer::plan_to_parquet; diff --git a/datafusion/core/src/datasource/physical_plan/parquet/opener.rs b/datafusion/core/src/datasource/physical_plan/parquet/opener.rs index 37912dd5b0e8..8557c6d5f950 100644 --- a/datafusion/core/src/datasource/physical_plan/parquet/opener.rs +++ b/datafusion/core/src/datasource/physical_plan/parquet/opener.rs @@ -20,10 +20,10 @@ use crate::datasource::physical_plan::parquet::page_filter::PagePruningPredicate; use crate::datasource::physical_plan::parquet::row_groups::RowGroupAccessPlanFilter; use crate::datasource::physical_plan::parquet::{ - row_filter, should_enable_page_index, ParquetAccessPlan, ParquetFileReaderFactory, + row_filter, should_enable_page_index, ParquetAccessPlan, }; use crate::datasource::physical_plan::{ - FileMeta, FileOpenFuture, FileOpener, ParquetFileMetrics, + FileMeta, FileOpenFuture, FileOpener, ParquetFileMetrics, ParquetFileReaderFactory, }; use crate::datasource::schema_adapter::SchemaAdapterFactory; use crate::physical_optimizer::pruning::PruningPredicate;