Skip to content

Commit 3dd706f

Browse files
committed
Add PhysicalExpr optimizer and cast unwrapping
1 parent 1884175 commit 3dd706f

File tree

11 files changed

+2068
-818
lines changed

11 files changed

+2068
-818
lines changed

Cargo.lock

Lines changed: 1 addition & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

datafusion/datasource-parquet/src/opener.rs

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@ use datafusion_common::pruning::{
3737
};
3838
use datafusion_common::{exec_err, Result};
3939
use datafusion_datasource::PartitionedFile;
40+
use datafusion_physical_expr::simplifier::PhysicalExprSimplifier;
4041
use datafusion_physical_expr::PhysicalExprSchemaRewriter;
4142
use datafusion_physical_expr_common::physical_expr::PhysicalExpr;
4243
use datafusion_physical_optimizer::pruning::PruningPredicate;
@@ -262,7 +263,13 @@ impl FileOpener for ParquetOpener {
262263
)
263264
.rewrite(p)
264265
.map_err(ArrowError::from)
266+
.map(|p| {
267+
PhysicalExprSimplifier::new(&physical_file_schema)
268+
.simplify(p)
269+
.map_err(ArrowError::from)
270+
})
265271
})
272+
.transpose()?
266273
.transpose()?;
267274

268275
// Build predicates for this specific file

0 commit comments

Comments
 (0)