Skip to content

Commit cdff5e2

Browse files
committed
fix format
1 parent e247819 commit cdff5e2

File tree

1 file changed

+4
-1
lines changed
  • datafusion/physical-plan/src/joins/hash_join

1 file changed

+4
-1
lines changed

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

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -804,7 +804,10 @@ impl HashJoinStream {
804804
// For null-aware anti join, filter out LEFT rows with NULL in join keys
805805
// BUT only if the probe side (RIGHT) was non-empty. If probe side is empty,
806806
// NULL NOT IN (empty) = TRUE, so NULL rows should be returned.
807-
if self.null_aware && self.join_type == JoinType::LeftAnti && self.probe_side_non_empty {
807+
if self.null_aware
808+
&& self.join_type == JoinType::LeftAnti
809+
&& self.probe_side_non_empty
810+
{
808811
// Since null_aware validation ensures single column join, we only check the first column
809812
let build_key_column = &build_side.left_data.values()[0];
810813

0 commit comments

Comments
 (0)