Optimized PartitionedOutput staging hub#1799
Conversation
|
alchemy link 86db93b |
|
Added new rebase item:
|
|
alchemy link 6dd3661 |
|
The following unexpired item was removed at
Added new rebase item:
|
|
alchemy link 2706c1e |
|
The following unexpired item was removed at
Added new rebase item:
|
|
alchemy link 86db93b,6dd3661c7afef52c42ed1c5ca83c9e57e21ec2b3,2706c1e80f9463bd4fdd805e296839f964437ca3 |
|
Failed to add new rebase item:
The new rebase item overlaps with the following existing item:
Please double check your input and retry. |
|
alchemy link 86db93b,6dd3661c7afef52c42ed1c5ca83c9e57e21ec2b3,2706c1e80f9463bd4fdd805e296839f964437ca3 @2026-03-10T12:01:55Z |
|
Failed to add new rebase item:
The new rebase item overlaps with the following existing item:
Please double check your input and retry. |
|
alchemy link 86db93b,6dd3661c7afef52c42ed1c5ca83c9e57e21ec2b3,2706c1e80f9463bd4fdd805e296839f964437ca3 @2026-03-12T13:19:10Z |
|
The following unexpired item was removed at
Added new rebase item:
|
|
Failed to cherry-pick commit 546d0bd in rebase request #2189: Please:
|
This commit introduces OptimizedPartitionedOutput, a PartitionedOutput operator backed by PrestoIterativePartitioningSerializer. Enabled via query config key "optimized_repartitioning" (default off). LocalPlanner selects it over the standard PartitionedOutput when the flag is set. TODO: replicateNullsAndAny is not yet supported and raises a user error.
…geBenchmark - Added normal vs optimized PartitionedOutput comparison by running each exchange case twice with kOptimizedPartitionedOutputEnabled=false/true. - Added per-mode benchmark names: - exchange<Case>_normalPartitionedOutput - exchange<Case>_optimizedPartitionedOutput in ExchangeBenchmark.cpp. - Refactored result printing into shared helpers and fixed output consistency in ExchangeBenchmark.cpp.
974bb09 to
ee25fa7
Compare
|
alchemy merge @2026-06-25T18:39:48Z |
|
alchemy link 23e8d1d,7df0be41dac449670584be5336587a1d3df135bf,5719f909a173ce08e483b900b6a2811da82e112b,fad80645718f89d4b3598859c2b51c2ebfd9e43e,04fbad0a3b5d14d5dc890ae4e05cf35f715ae194,c3a52c9e9b46e6c6abb3d40b7f978bfac833d9eb,9efe82a5fb4e13a348573cb4d4f893541cea47d0,ff888e7bd593f0a909bc75b0b7213b3200e968b1,1511c01f8c5e7b36c77f52a0c8a7a558d3c99676,e567d50501a13f650c8d25cc18d045379631b1dc,ee25fa7738c87a1da498e4ff679cd2fa8abd8684 @2026-06-25T18:39:48Z |
|
The following unexpired item was removed at
Added new rebase item:
|
This PR is to track the commits for the optimized PartitionedOutput operator. Related new PRs shall be submitted to optimized_partitionedoutput branch, and then alchemy merge to oss-main.
Review history of the first two commits can be found in
feat: Introducing PartitionedVector #1596
feat: Add PartitionedRowVector implementation #1770