Skip to content

Commit

Permalink
Minor: Use resize instead of extend for adding static values in S…
Browse files Browse the repository at this point in the history
…ortMergeJoin logic (#13861)

Thanks @Dandandan
  • Loading branch information
comphead authored Dec 20, 2024
1 parent 75202b5 commit 9b19d36
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions datafusion/physical-plan/src/joins/sort_merge_join.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1578,7 +1578,7 @@ impl SortMergeJoinStream {
.append_nulls(num_rows);
self.output_record_batches
.batch_ids
.extend(vec![0; num_rows]);
.resize(self.output_record_batches.batch_ids.len() + num_rows, 0);

self.output_record_batches.batches.push(record_batch);
}
Expand Down Expand Up @@ -1622,7 +1622,7 @@ impl SortMergeJoinStream {
.append_nulls(num_rows);
self.output_record_batches
.batch_ids
.extend(vec![0; num_rows]);
.resize(self.output_record_batches.batch_ids.len() + num_rows, 0);
self.output_record_batches.batches.push(record_batch);
}
buffered_batch.join_filter_not_matched_map.clear();
Expand Down Expand Up @@ -1757,10 +1757,10 @@ impl SortMergeJoinStream {
self.output_record_batches.filter_mask.extend(pre_mask);
}
self.output_record_batches.row_indices.extend(&left_indices);
self.output_record_batches.batch_ids.extend(vec![
self.streamed_batch_counter.load(Relaxed);
left_indices.len()
]);
self.output_record_batches.batch_ids.resize(
self.output_record_batches.batch_ids.len() + left_indices.len(),
self.streamed_batch_counter.load(Relaxed),
);

// For outer joins, we need to push the null joined rows to the output if
// all joined rows are failed on the join filter.
Expand Down

0 comments on commit 9b19d36

Please sign in to comment.