-
Notifications
You must be signed in to change notification settings - Fork 3.6k
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
ARROW-6091: [Rust] [DataFusion] Implement physical execution plan for LIMIT #5509
Conversation
// collect up to "limit" rows on each partition | ||
let threads: Vec<JoinHandle<Result<Vec<RecordBatch>>>> = self | ||
.partitions | ||
.iter() |
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.
Would be an overkill to use rayon's par_iter()?
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.
For this round my plan was to keep things simple and do a second round of optimizations that I've started tracking in https://jira.apache.org/jira/browse/ARROW-6689 and in particular see the subtask https://jira.apache.org/jira/browse/ARROW-6691 related to threading.
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.
I think that's a "no" for rayon :D
@nevi-me @sunchao @paddyhoran Please review when you can. Thanks. |
@nevi-me @sunchao @paddyhoran Any objection to me merging this one? |
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.
I only did a high level review but LGTM. I'm in favor of merging and opening follow up issues if we find anything (particularly when it comes to your PR's to DataFusion) to keep the momentum going.
… LIMIT Closes #5509 from andygrove/ARROW-6091 and squashes the following commits: cb5c622 <Andy Grove> bump nightly version 00078c7 <Andy Grove> minor optimization 0c91602 <Andy Grove> test passes 40e617f <Andy Grove> unit test 3cb4cab <Andy Grove> start roughing out LIMIT Authored-by: Andy Grove <[email protected]> Signed-off-by: Andy Grove <[email protected]>
No description provided.