Skip to content

Commit

Permalink
[Minor] Move combine_join util to under equivalence.rs (#7917)
Browse files Browse the repository at this point in the history
* Move combine join to equivalences.rs file

* Resolve linter errors

* Simplifications, do not return Error in add_offset
  • Loading branch information
mustafasrepo authored Oct 24, 2023
1 parent 10eabd6 commit 8068d7f
Show file tree
Hide file tree
Showing 9 changed files with 368 additions and 367 deletions.
2 changes: 1 addition & 1 deletion datafusion/core/src/physical_optimizer/sort_pushdown.rs
Original file line number Diff line number Diff line change
Expand Up @@ -343,7 +343,7 @@ fn try_pushdown_requirements_to_join(
smj.left().schema().fields.len(),
&smj.maintains_input_order(),
Some(SortMergeJoinExec::probe_side(&smj.join_type())),
)?;
);
Ok(ordering_satisfy_requirement(
new_output_ordering.as_deref(),
parent_required,
Expand Down
Loading

0 comments on commit 8068d7f

Please sign in to comment.