Skip to content

Commit d9c1878

Browse files
committed
Move some datafusion-optimizer::utils down to datafusion-expr::utils
These utils manipulate `LogicalPlan`s and `Expr`s and may be useful in projects that only depend on `datafusion-expr`
1 parent f1dbb2d commit d9c1878

File tree

16 files changed

+499
-337
lines changed

16 files changed

+499
-337
lines changed

benchmarks/src/parquet_filter.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,8 +19,8 @@ use crate::AccessLogOpt;
1919
use crate::{BenchmarkRun, CommonOpt};
2020
use arrow::util::pretty;
2121
use datafusion::common::Result;
22+
use datafusion::logical_expr::utils::disjunction;
2223
use datafusion::logical_expr::{lit, or, Expr};
23-
use datafusion::optimizer::utils::disjunction;
2424
use datafusion::physical_plan::collect;
2525
use datafusion::prelude::{col, SessionContext};
2626
use datafusion::test_util::parquet::{ParquetScanOptions, TestParquetFile};

datafusion/core/src/datasource/listing/table.rs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -40,11 +40,10 @@ use crate::datasource::{
4040
physical_plan::{is_plan_streaming, FileScanConfig, FileSinkConfig},
4141
TableProvider, TableType,
4242
};
43-
use crate::logical_expr::TableProviderFilterPushDown;
4443
use crate::{
4544
error::{DataFusionError, Result},
4645
execution::context::SessionState,
47-
logical_expr::Expr,
46+
logical_expr::{utils::conjunction, Expr, TableProviderFilterPushDown},
4847
physical_plan::{empty::EmptyExec, ExecutionPlan, Statistics},
4948
};
5049

@@ -56,7 +55,6 @@ use datafusion_common::{
5655
};
5756
use datafusion_execution::cache::cache_manager::FileStatisticsCache;
5857
use datafusion_execution::cache::cache_unit::DefaultFileStatisticsCache;
59-
use datafusion_optimizer::utils::conjunction;
6058
use datafusion_physical_expr::{
6159
create_physical_expr, LexOrdering, PhysicalSortRequirement,
6260
};

datafusion/core/tests/parquet/filter_pushdown.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ use datafusion::physical_plan::collect;
3434
use datafusion::physical_plan::metrics::MetricsSet;
3535
use datafusion::prelude::{col, lit, lit_timestamp_nano, Expr, SessionContext};
3636
use datafusion::test_util::parquet::{ParquetScanOptions, TestParquetFile};
37-
use datafusion_optimizer::utils::{conjunction, disjunction, split_conjunction};
37+
use datafusion_expr::utils::{conjunction, disjunction, split_conjunction};
3838
use itertools::Itertools;
3939
use parquet::file::properties::WriterProperties;
4040
use tempfile::TempDir;

0 commit comments

Comments
 (0)