Skip to content

Commit b6bab83

Browse files
committed
fmt
1 parent fc2ce21 commit b6bab83

File tree

2 files changed

+7
-3
lines changed

2 files changed

+7
-3
lines changed

datafusion/datasource-parquet/src/source.rs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -632,8 +632,10 @@ impl FileSource for ParquetSource {
632632
// If pushdown_filters is false we tell our parents that they still have to handle the filters,
633633
// even if we updated the predicate to include the filters (they will only be used for stats pruning).
634634
if !pushdown_filters {
635-
return Ok(FilterPushdownPropagation::with_filters(filters.make_unsupported())
636-
.with_updated_node(source));
635+
return Ok(FilterPushdownPropagation::with_filters(
636+
filters.make_unsupported(),
637+
)
638+
.with_updated_node(source));
637639
}
638640
Ok(FilterPushdownPropagation::with_filters(filters).with_updated_node(source))
639641
}

datafusion/physical-plan/src/filter_pushdown.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,9 @@ pub enum PredicateSupport {
3434
impl PredicateSupport {
3535
pub fn into_inner(self) -> Arc<dyn PhysicalExpr> {
3636
match self {
37-
PredicateSupport::Supported(expr) | PredicateSupport::Unsupported(expr) => expr,
37+
PredicateSupport::Supported(expr) | PredicateSupport::Unsupported(expr) => {
38+
expr
39+
}
3840
}
3941
}
4042
}

0 commit comments

Comments
 (0)