-
Notifications
You must be signed in to change notification settings - Fork 5.9k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
executor: control Chunk size for Joiners #9614
Conversation
Codecov Report
@@ Coverage Diff @@
## master #9614 +/- ##
================================================
+ Coverage 67.2176% 67.2471% +0.0294%
================================================
Files 381 381
Lines 79851 79874 +23
================================================
+ Hits 53674 53713 +39
+ Misses 21389 21380 -9
+ Partials 4788 4781 -7 |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
43236fa
to
898e1f0
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
rest LGTM and @zz-jason PTAL
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
hash join also need to consider the "is outer join" property.
6887f67
to
a46a6d5
Compare
a46a6d5
to
3e9f945
Compare
All comments have been addressed, PTAL @zz-jason @lzmhhh123 |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
/run-all-tests |
What problem does this PR solve?
Control the number of rows in chunks returned by
joiner
and join-like executors.Following up #9452, this PR is a subtask of #9166.
What is changed and how it works?
For
MergeJoin
,HashJoin
andIndexLookupJoin
, supportrequiredRows
from parents and pushrequiredRows
down to its outer child if it is outer join.Check List
Tests