Skip to content

Commit c249b07

Browse files
committed
Enable row pushdown and predicate reordering by default
1 parent 23b4495 commit c249b07

File tree

2 files changed

+7
-11
lines changed

2 files changed

+7
-11
lines changed

datafusion/core/src/config.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -240,20 +240,20 @@ impl BuiltInConfigs {
240240
OPT_PARQUET_PUSHDOWN_FILTERS,
241241
"If true, filter expressions are be applied during the parquet decoding operation to \
242242
reduce the number of rows decoded.",
243-
false,
243+
true,
244244
),
245245
ConfigDefinition::new_bool(
246246
OPT_PARQUET_REORDER_FILTERS,
247247
"If true, filter expressions evaluated during the parquet decoding opearation \
248248
will be reordered heuristically to minimize the cost of evaluation. If false, \
249249
the filters are applied in the same order as written in the query.",
250-
false,
250+
true,
251251
),
252252
ConfigDefinition::new_bool(
253253
OPT_PARQUET_ENABLE_PAGE_INDEX,
254254
"If true, uses parquet data page level metadata (Page Index) statistics \
255255
to reduce the number of rows decoded.",
256-
false,
256+
true,
257257
),
258258
ConfigDefinition::new_bool(
259259
OPT_OPTIMIZER_SKIP_FAILED_RULES,

datafusion/core/src/physical_plan/file_format/parquet.rs

Lines changed: 4 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -803,7 +803,7 @@ mod tests {
803803
let file_groups = meta.into_iter().map(Into::into).collect();
804804

805805
// prepare the scan
806-
let mut parquet_exec = ParquetExec::new(
806+
let parquet_exec = ParquetExec::new(
807807
FileScanConfig {
808808
object_store_url: ObjectStoreUrl::local_filesystem(),
809809
file_groups: vec![file_groups],
@@ -817,13 +817,9 @@ mod tests {
817817
},
818818
predicate,
819819
None,
820-
);
821-
822-
if pushdown_predicate {
823-
parquet_exec = parquet_exec
824-
.with_pushdown_filters(true)
825-
.with_reorder_filters(true);
826-
}
820+
)
821+
.with_pushdown_filters(pushdown_predicate)
822+
.with_reorder_filters(pushdown_predicate);
827823

828824
if page_index_predicate {
829825
parquet_exec = parquet_exec.with_enable_page_index(true);

0 commit comments

Comments
 (0)