Skip to content

refactor sort exec stream and combine batches - #515

Merged
alamb merged 1 commit into
apache:masterfrom
jimexist:refactor-combine-batches
Jun 7, 2021
Merged

refactor sort exec stream and combine batches#515
alamb merged 1 commit into
apache:masterfrom
jimexist:refactor-combine-batches

Conversation

@jimexist

@jimexistjimexist commented Jun 6, 2021

Copy link
Copy Markdown
Member

Which issue does this PR close?

to make way for #360 I'll need the combine batches fn, so i'll refactor the current sort exec stream and add some integration test by the way

this pull request is used by #516

Rationale for this change

What changes are included in this PR?

Are there any user-facing changes?

@codecov-commenter

codecov-commenter commented Jun 6, 2021

Copy link
Copy Markdown

Codecov Report

Merging #515 (1c0dea8) into master (b84789a) will increase coverage by 0.02%.
The diff coverage is 100.00%.

Impacted file tree graph

@@ Coverage Diff @@## master #515 +/- ##
==========================================
+ Coverage 76.09% 76.11% +0.02% 
==========================================
Files 155 155 Lines 26575 26602 +27 ==========================================
+ Hits 20221 20249 +28 + Misses 6354 6353 -1 
Impacted FilesCoverage Δ
datafusion/src/physical_plan/common.rs91.66% <100.00%> (+7.45%)⬆️
datafusion/src/physical_plan/sort.rs91.95% <100.00%> (+0.21%)⬆️

Continue to review full report at Codecov.

Legend - Click here to learn more
Δ = absolute <relative> (impact), ø = not affected, ? = missing data
Powered by Codecov. Last update b84789a...1c0dea8. Read the comment docs.

@jimexist
jimexistforce-pushed the refactor-combine-batches branch 2 times, most recently from 49ddfd3 to a0430e1CompareJune 6, 2021 05:40

@DandandanDandandan left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

👍

let result = combined
.map(|batch| sort_batch(batch, schema, &expr))
.transpose()?;
sort_time.add(now.elapsed().as_nanos() as usize);

Copy link
Copy Markdown
MemberAuthor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Note here the semantic is changed because on err it would no longer log a metric which shall be the correct behavior

@jimexist
jimexistforce-pushed the refactor-combine-batches branch from a0430e1 to 248ba2fCompareJune 7, 2021 03:21
@jimexist
jimexistforce-pushed the refactor-combine-batches branch from 248ba2f to de4055bCompareJune 7, 2021 12:00

@alambalamb left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks @jimexist !

@alamb
alamb merged commit 5773a03 into apache:masterJun 7, 2021
@jimexist
jimexist deleted the refactor-combine-batches branch June 7, 2021 16:24
@houqphouqp added bug Something isn't working datafusion labels Jul 30, 2021
@alambalamb mentioned this pull request Jun 6, 2022
HairstonE pushed a commit to HairstonE/datafusion that referenced this pull request Oct 7, 2025
* use DataFusion 32
* update lock file
Sign up for freeto join this conversation on GitHub. Already have an account? Sign in to comment

Labels

bugSomething isn't working

Projects

None yet

Development

Successfully merging this pull request may close these issues.

5 participants

@jimexist@codecov-commenter@Dandandan@alamb@houqp