Skip to content

Commit 04efcc1

Browse files
committed
fmt
1 parent 37b61f5 commit 04efcc1

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

datafusion/physical-plan/src/joins/hash_join.rs

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1017,14 +1017,14 @@ impl ExecutionPlan for HashJoinExec {
10171017
.iter()
10181018
.any(|col| right_column_names.contains(col.name()));
10191019
// Some join types produce extra columns, e.g. `mark` columns in RightMark joins or LeftMark joins.
1020-
let references_non_child_columns = referenced_columns
1021-
.iter()
1022-
.any(|col| {
1023-
!left_column_names.contains(col.name())
1024-
&& !right_column_names.contains(col.name())
1025-
});
1020+
let references_non_child_columns = referenced_columns.iter().any(|col| {
1021+
!left_column_names.contains(col.name())
1022+
&& !right_column_names.contains(col.name())
1023+
});
10261024

1027-
if references_non_child_columns || (references_left_columns && references_right_columns) {
1025+
if references_non_child_columns
1026+
|| (references_left_columns && references_right_columns)
1027+
{
10281028
// Filter references both sides - cannot push down, skip it
10291029
left_filters.push(PredicateSupport::Unsupported(Arc::clone(filter)));
10301030
right_filters.push(PredicateSupport::Unsupported(Arc::clone(filter)));

0 commit comments

Comments
 (0)