Don't add filters to used columns

Dandandan · Sep 27, 2023 · 08d2943 · 08d2943
1 parent 32dfbb0
commit 08d2943
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/datafusion/optimizer/src/push_down_projection.rs b/datafusion/optimizer/src/push_down_projection.rs
@@ -147,11 +147,12 @@ impl OptimizerRule for PushDownProjection {
                 if !scan.projected_schema.fields().is_empty() =>
             {
                 let mut used_columns: HashSet<Column> = HashSet::new();
-                // filter expr may not exist in expr in projection.
-                // like: TableScan: t1 projection=[bool_col, int_col], full_filters=[t1.id = Int32(1)]
-                // projection=[bool_col, int_col] don't contain `ti.id`.
-                exprlist_to_columns(&scan.filters, &mut used_columns)?;
                 if projection_is_empty {
+                    // filter expr may not exist in expr in projection.
+                    // like: TableScan: t1 projection=[bool_col, int_col], full_filters=[t1.id = Int32(1)]
+                    // projection=[bool_col, int_col] don't contain `ti.id`.
+                    exprlist_to_columns(&scan.filters, &mut used_columns)?;
+
                     used_columns
                         .insert(scan.projected_schema.fields()[0].qualified_column());
                     push_down_scan(&used_columns, scan, true)?