Skip to content

Commit

Permalink
Fix clippy
Browse files Browse the repository at this point in the history
  • Loading branch information
viirya committed Jan 31, 2024
1 parent d9e40af commit 00d4160
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions datafusion/physical-plan/src/joins/sort_merge_join.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1223,23 +1223,23 @@ impl SMJStream {
/// Gets the arrays which join filters are applied on.
fn get_filter_column(
join_filter: &Option<JoinFilter>,
streamed_columns: &Vec<ArrayRef>,
buffered_columns: &Vec<ArrayRef>,
streamed_columns: &[ArrayRef],
buffered_columns: &[ArrayRef],
) -> Vec<ArrayRef> {
let mut filter_columns = vec![];

if let Some(f) = join_filter {
let left_columns = f
.column_indices()
.iter()
.filter(|col_index| (*col_index).side == JoinSide::Left)
.filter(|col_index| col_index.side == JoinSide::Left)
.map(|i| streamed_columns[i.index].clone())
.collect::<Vec<_>>();

let right_columns = f
.column_indices()
.iter()
.filter(|col_index| (*col_index).side == JoinSide::Right)
.filter(|col_index| col_index.side == JoinSide::Right)
.map(|i| buffered_columns[i.index].clone())
.collect::<Vec<_>>();

Expand Down

0 comments on commit 00d4160

Please sign in to comment.