Skip to content

Commit f2e6701

Browse files
korowaalamb
andauthored
feat: emitting partial join results in HashJoinStream (#8020)
* HashJoin partial batch emitting * batch splitting tests * stream state & extended tests * fmt & clippy warns fixed * Apply suggestions from code review Co-authored-by: Andrew Lamb <[email protected]> * review comments * ported join limited output * comments & formatting * Reuse hashes buffer * Apply suggestions from code review Co-authored-by: Andrew Lamb <[email protected]> * fixed metrics and updated comment * precalculate hashes & remove iterators * draft: preparing for review --------- Co-authored-by: Andrew Lamb <[email protected]>
1 parent 38d5f75 commit f2e6701

File tree

7 files changed

+736
-284
lines changed

7 files changed

+736
-284
lines changed

datafusion/physical-plan/Cargo.toml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,7 @@ uuid = { version = "^1.2", features = ["v4"] }
6161

6262
[dev-dependencies]
6363
rstest = { workspace = true }
64+
rstest_reuse = "0.6.0"
6465
termtree = "0.4.1"
6566
tokio = { version = "1.28", features = [
6667
"macros",

0 commit comments

Comments
 (0)