move

Author: adriangb

Cargo.lock

@@ -136,6 +136,7 @@ datafusion-functions-window-common = { path = "datafusion/functions-window-commo
 datafusion-macros = { path = "datafusion/macros", version = "48.0.0" }
 datafusion-optimizer = { path = "datafusion/optimizer", version = "48.0.0", default-features = false }
 datafusion-physical-expr = { path = "datafusion/physical-expr", version = "48.0.0", default-features = false }
+datafusion-physical-expr-adapter = { path = "datafusion/physical-expr-adapter", version = "48.0.0", default-features = false }
 datafusion-physical-expr-common = { path = "datafusion/physical-expr-common", version = "48.0.0", default-features = false }
 datafusion-physical-optimizer = { path = "datafusion/physical-optimizer", version = "48.0.0" }
 datafusion-physical-plan = { path = "datafusion/physical-plan", version = "48.0.0" }

Cargo.toml

@@ -42,6 +42,7 @@ datafusion-execution = { workspace = true }
 datafusion-expr = { workspace = true }
 datafusion-functions-aggregate = { workspace = true }
 datafusion-physical-expr = { workspace = true }
+datafusion-physical-expr-adapter = { workspace = true }
 datafusion-physical-expr-common = { workspace = true }
 datafusion-physical-optimizer = { workspace = true }
 datafusion-physical-plan = { workspace = true }

datafusion/datasource-parquet/Cargo.toml

@@ -37,7 +37,7 @@ use datafusion_common::pruning::{
 };
 use datafusion_common::{exec_err, Result};
 use datafusion_datasource::PartitionedFile;
-use datafusion_physical_expr::PhysicalExprSchemaRewriter;
+use datafusion_physical_expr_adapter::PhysicalExprSchemaRewriter;
 use datafusion_physical_expr_common::physical_expr::PhysicalExpr;
 use datafusion_physical_optimizer::pruning::PruningPredicate;
 use datafusion_physical_plan::metrics::{Count, ExecutionPlanMetricsSet, MetricBuilder};

datafusion/datasource-parquet/src/opener.rs

@@ -38,7 +38,6 @@ mod partitioning;
 mod physical_expr;
 pub mod planner;
 mod scalar_function;
-pub mod schema_rewriter;
 pub mod statistics;
 pub mod utils;
 pub mod window;
@@ -69,7 +68,6 @@ pub use datafusion_physical_expr_common::sort_expr::{
 
 pub use planner::{create_physical_expr, create_physical_exprs};
 pub use scalar_function::ScalarFunctionExpr;
-pub use schema_rewriter::PhysicalExprSchemaRewriter;
 pub use utils::{conjunction, conjunction_opt, split_conjunction};
 
 // For backwards compatibility