Skip to content

Commit cb8c1f1

Browse files
committed
Use a single map
1 parent 030444d commit cb8c1f1

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

datafusion/optimizer/src/eliminate_cross_join.rs

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -174,14 +174,12 @@ impl OptimizerRule for EliminateCrossJoin {
174174
// If there are no join keys then do nothing:
175175
if all_join_keys.is_empty() {
176176
Filter::try_new(predicate, Arc::new(left))
177-
.map(LogicalPlan::Filter)
178-
.map(Transformed::yes)
177+
.map(|filter| Transformed::yes(LogicalPlan::Filter(filter)))
179178
} else {
180179
// Remove join expressions from filter:
181180
match remove_join_expressions(predicate, &all_join_keys) {
182181
Some(filter_expr) => Filter::try_new(filter_expr, Arc::new(left))
183-
.map(LogicalPlan::Filter)
184-
.map(Transformed::yes),
182+
.map(|filter| Transformed::yes(LogicalPlan::Filter(filter))),
185183
_ => Ok(Transformed::yes(left)),
186184
}
187185
}

0 commit comments

Comments
 (0)