Skip to content

Commit

Permalink
joinp: tweak to conform with latest polars
Browse files Browse the repository at this point in the history
  • Loading branch information
jqnatividad committed Aug 30, 2024
1 parent ed9727c commit d61e6e2
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/cmd/joinp.rs
Original file line number Diff line number Diff line change
Expand Up @@ -430,7 +430,7 @@ impl JoinStruct {

optflags.set(OptFlags::STREAMING, self.streaming);

// log::debug!("Optimization state: {optimization_state:?}");
// log::debug!("Optimization flags: {optimization_flags:?}");

let join_results = if jointype == JoinType::Cross {
// cross join doesn't need join columns
Expand All @@ -452,7 +452,7 @@ impl JoinStruct {

self.left_lf = self
.left_lf
.sort(&left_selcols_vec, SortMultipleOptions::default());
.sort(left_selcols_vec, SortMultipleOptions::default());

let right_selcols_vec: Vec<PlSmallStr> = self
.right_sel
Expand All @@ -462,7 +462,7 @@ impl JoinStruct {

self.right_lf = self
.right_lf
.sort(&right_selcols_vec, SortMultipleOptions::default());
.sort(right_selcols_vec, SortMultipleOptions::default());
}

self.left_lf
Expand Down

0 comments on commit d61e6e2

Please sign in to comment.