From f66cce3e44defe0de8c42ef4ff78a4369ca9790c Mon Sep 17 00:00:00 2001 From: yangjiang Date: Sat, 13 Apr 2024 23:38:43 +0800 Subject: [PATCH] simply expr --- datafusion/core/src/physical_optimizer/pruning.rs | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/datafusion/core/src/physical_optimizer/pruning.rs b/datafusion/core/src/physical_optimizer/pruning.rs index da4895fa13d1..d8a3814d77e1 100644 --- a/datafusion/core/src/physical_optimizer/pruning.rs +++ b/datafusion/core/src/physical_optimizer/pruning.rs @@ -1261,14 +1261,12 @@ fn build_is_null_column_expr( required_columns .null_count_column_expr(col, expr, null_count_field) .map(|null_count_column_expr| { - // IsNotNull(column) => null_count == row_count - // but use false to prune the whole unit so need add the negate - let equal_expr = Arc::new(phys_expr::BinaryExpr::new( + // IsNotNull(column) => null_count != row_count + Arc::new(phys_expr::BinaryExpr::new( null_count_column_expr, - Operator::Eq, + Operator::NotEq, row_count_expr, - )); - Arc::new(phys_expr::NotExpr::new(equal_expr)) as _ + )) as _ }) .ok() } else {