Skip to content

Commit

Permalink
Minor: reduce some #cfg(feature = "parquet")
Browse files Browse the repository at this point in the history
  • Loading branch information
alamb committed Oct 25, 2023
1 parent 3ba5d6d commit 976dd84
Show file tree
Hide file tree
Showing 4 changed files with 2 additions and 8 deletions.
3 changes: 1 addition & 2 deletions datafusion/core/src/datasource/file_format/parquet.rs
Original file line number Diff line number Diff line change
Expand Up @@ -33,11 +33,10 @@ use crate::arrow::datatypes::DataType;
use crate::config::ConfigOptions;

use crate::datasource::file_format::file_compression_type::FileCompressionType;
use crate::datasource::get_col_stats;
use crate::datasource::physical_plan::{
FileGroupDisplay, FileMeta, FileSinkConfig, ParquetExec, SchemaAdapter,
};
use crate::datasource::statistics::create_max_min_accs;
use crate::datasource::statistics::{create_max_min_accs, get_col_stats};
use crate::error::Result;
use crate::execution::context::SessionState;
use crate::physical_plan::expressions::{MaxAccumulator, MinAccumulator};
Expand Down
2 changes: 0 additions & 2 deletions datafusion/core/src/datasource/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -42,6 +42,4 @@ pub use self::memory::MemTable;
pub use self::provider::TableProvider;
pub use self::view::ViewTable;
pub use crate::logical_expr::TableType;
#[cfg(feature = "parquet")]
pub(crate) use statistics::get_col_stats;
pub use statistics::get_statistics_with_limit;
2 changes: 0 additions & 2 deletions datafusion/core/src/datasource/physical_plan/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -30,8 +30,6 @@ pub(crate) use self::csv::plan_to_csv;
pub use self::csv::{CsvConfig, CsvExec, CsvOpener};
pub(crate) use self::json::plan_to_json;
#[cfg(feature = "parquet")]
pub(crate) use self::parquet::plan_to_parquet;
#[cfg(feature = "parquet")]
pub use self::parquet::{ParquetExec, ParquetFileMetrics, ParquetFileReaderFactory};

pub use arrow_file::ArrowExec;
Expand Down
3 changes: 1 addition & 2 deletions datafusion/core/src/execution/context/parquet.rs
Original file line number Diff line number Diff line change
Expand Up @@ -17,10 +17,9 @@

use std::sync::Arc;

use crate::datasource::physical_plan::parquet::plan_to_parquet;
use parquet::file::properties::WriterProperties;

use crate::datasource::physical_plan::plan_to_parquet;

use super::super::options::{ParquetReadOptions, ReadOptions};
use super::{DataFilePaths, DataFrame, ExecutionPlan, Result, SessionContext};

Expand Down

0 comments on commit 976dd84

Please sign in to comment.