diff --git a/datafusion/core/src/config.rs b/datafusion/core/src/config.rs index 620634f259bac..c9dd56fbdd6d8 100644 --- a/datafusion/core/src/config.rs +++ b/datafusion/core/src/config.rs @@ -240,20 +240,20 @@ impl BuiltInConfigs { OPT_PARQUET_PUSHDOWN_FILTERS, "If true, filter expressions are be applied during the parquet decoding operation to \ reduce the number of rows decoded.", - false, + true, ), ConfigDefinition::new_bool( OPT_PARQUET_REORDER_FILTERS, "If true, filter expressions evaluated during the parquet decoding opearation \ will be reordered heuristically to minimize the cost of evaluation. If false, \ the filters are applied in the same order as written in the query.", - false, + true, ), ConfigDefinition::new_bool( OPT_PARQUET_ENABLE_PAGE_INDEX, "If true, uses parquet data page level metadata (Page Index) statistics \ to reduce the number of rows decoded.", - false, + true, ), ConfigDefinition::new_bool( OPT_OPTIMIZER_SKIP_FAILED_RULES, diff --git a/datafusion/core/src/physical_plan/file_format/parquet.rs b/datafusion/core/src/physical_plan/file_format/parquet.rs index 596d2b09e9506..99c7409a0e3bb 100644 --- a/datafusion/core/src/physical_plan/file_format/parquet.rs +++ b/datafusion/core/src/physical_plan/file_format/parquet.rs @@ -817,13 +817,9 @@ mod tests { }, predicate, None, - ); - - if pushdown_predicate { - parquet_exec = parquet_exec - .with_pushdown_filters(true) - .with_reorder_filters(true); - } + ) + .with_pushdown_filters(pushdown_predicate) + .with_reorder_filters(pushdown_predicate); if page_index_predicate { parquet_exec = parquet_exec.with_enable_page_index(true);