Skip to content

Commit a892300

Browse files
authored
Minor: reduce some #cfg(feature = "parquet") (#7929)
1 parent 6e87f59 commit a892300

File tree

4 files changed

+2
-9
lines changed

4 files changed

+2
-9
lines changed

datafusion/core/src/datasource/file_format/parquet.rs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ use tokio::sync::mpsc::{self, Receiver, Sender};
3636
use tokio::task::{JoinHandle, JoinSet};
3737

3838
use crate::datasource::file_format::file_compression_type::FileCompressionType;
39-
use crate::datasource::statistics::create_max_min_accs;
39+
use crate::datasource::statistics::{create_max_min_accs, get_col_stats};
4040
use arrow::datatypes::SchemaRef;
4141
use arrow::datatypes::{Fields, Schema};
4242
use bytes::{BufMut, BytesMut};
@@ -63,11 +63,9 @@ use crate::arrow::array::{
6363
use crate::arrow::datatypes::DataType;
6464
use crate::config::ConfigOptions;
6565

66-
use crate::datasource::get_col_stats;
6766
use crate::datasource::physical_plan::{
6867
FileGroupDisplay, FileMeta, FileSinkConfig, ParquetExec, SchemaAdapter,
6968
};
70-
7169
use crate::error::Result;
7270
use crate::execution::context::SessionState;
7371
use crate::physical_plan::expressions::{MaxAccumulator, MinAccumulator};

datafusion/core/src/datasource/mod.rs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,4 @@ pub use self::memory::MemTable;
4242
pub use self::provider::TableProvider;
4343
pub use self::view::ViewTable;
4444
pub use crate::logical_expr::TableType;
45-
#[cfg(feature = "parquet")]
46-
pub(crate) use statistics::get_col_stats;
4745
pub use statistics::get_statistics_with_limit;

datafusion/core/src/datasource/physical_plan/mod.rs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,8 +30,6 @@ pub(crate) use self::csv::plan_to_csv;
3030
pub use self::csv::{CsvConfig, CsvExec, CsvOpener};
3131
pub(crate) use self::json::plan_to_json;
3232
#[cfg(feature = "parquet")]
33-
pub(crate) use self::parquet::plan_to_parquet;
34-
#[cfg(feature = "parquet")]
3533
pub use self::parquet::{ParquetExec, ParquetFileMetrics, ParquetFileReaderFactory};
3634

3735
pub use arrow_file::ArrowExec;

datafusion/core/src/execution/context/parquet.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,10 +17,9 @@
1717

1818
use std::sync::Arc;
1919

20+
use crate::datasource::physical_plan::parquet::plan_to_parquet;
2021
use parquet::file::properties::WriterProperties;
2122

22-
use crate::datasource::physical_plan::plan_to_parquet;
23-
2423
use super::super::options::{ParquetReadOptions, ReadOptions};
2524
use super::{DataFilePaths, DataFrame, ExecutionPlan, Result, SessionContext};
2625

0 commit comments

Comments
 (0)