Skip to content

rfc: distributed dynamic filtering#553

Draft
jayshrivastava wants to merge 8 commits into
branch-55from
js/dynamic-filtering-design
Draft

rfc: distributed dynamic filtering#553
jayshrivastava wants to merge 8 commits into
branch-55from
js/dynamic-filtering-design

Conversation

@jayshrivastava

@jayshrivastava jayshrivastava commented Jul 14, 2026

Copy link
Copy Markdown
Collaborator

Informs #528

@jayshrivastava jayshrivastava changed the base branch from main to branch-55 July 14, 2026 19:12
@jayshrivastava jayshrivastava changed the title Js/dynamic filtering design rfc: distributed dynamic filtering Jul 14, 2026
┌──────────────────────────────┐ ┌──────────────────────────────┐
│ ┌──────────────────────────┐ │ │ ┌──────────────────────────┐ │
│ │ RepartitionExec │ │ │ │ RepartitionExec │ │
│ │ partitioning=Hash(a, 12) │ │ │ │ partitioning=Hash(a, 12) │ │

Copy link
Copy Markdown
Collaborator Author

Choose a reason for hiding this comment

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

The partitioning here is hash(a) % 12 but in the above stage it's hash(a) % 4 assuming 4 target_partitions. So, the hash join will generate 4 cases.

It's actually not correct to merge all of the cases. We need to OR within each case.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant