[Analytics-Engine][MPP] Move MPP exchange placement into top-down CBO - #22833

Open

LantaoJin wants to merge 79 commits into

opensearch-project:mainfrom

LantaoJin:feature/mpp-top-down-traits

Commits on Aug 18, 2026

[Analytics Engine] Add PhysicalNode trait hooks and Convention.enforce for top-down MPP planning
LantaoJin
committed
0f2d038
[Analytics Engine] Add top-down trait hooks for transparent Project and Filter
LantaoJin
committed
615ec4b

Commits on Aug 19, 2026

[Analytics Engine] Add top-down trait hooks for Sort, Aggregate and Join behind setTopDownOpt
LantaoJin
committed
5e203cd
[Analytics Engine] Treat worker-tier joins as resolved in the coordinator split rule
LantaoJin
committed
6182bf4
[Analytics Engine] Charge coordinator gathers that collapse parallelism in the cost model
LantaoJin
committed
5b1b68e
[Analytics Engine] Exclude replicated broadcast inputs from the parallelism-collapse charge
LantaoJin
committed
3391f0b
[Analytics Engine] Stop RIGHT and FULL joins advertising a left-key hash partitioning
LantaoJin
committed
7d134bf
[Analytics Engine] Credit join cost for the parallelism its distribution provides
LantaoJin
committed
fa0bb79
[Analytics Engine] Restore the reducer cost formula now that the join models parallelism
LantaoJin
committed
c2d117f
[Analytics Engine] Document what blocks removing the distribution enforcement pass
LantaoJin
committed
36d9997
[Analytics Engine] Correct the enforcement-pass removal analysis with measured trait staleness
LantaoJin
committed
5705438
[Analytics Engine] Make the distribution trait tier-aware for materialized shuffles
LantaoJin
committed
1f22965
[Analytics Engine] Restamp rebuilt operator traits and gather via the satisfies-gated enforcer
LantaoJin
committed
c2b1421
[Analytics Engine] Record the measured root cause of enforcement-pass trait staleness
LantaoJin
committed
1024873
[Analytics Engine] Let the aggregate split rule see hash-partitioned and distributed-join inputs
LantaoJin
committed
aca15b7
[Analytics Engine] Record why the aggregate split rule still defers to the enforcement pass
LantaoJin
committed
f59cd35
[Analytics Engine] Gate the aggregate split rule on the distributed-aggregation toggle
LantaoJin
committed
434f62c
[Analytics Engine] Record why the size floor and SINGLE alternative cannot move yet
LantaoJin
committed
28f11dc
[Analytics Engine] Record that cost cannot replace the distribution size floor
LantaoJin
committed
daa6132
[Analytics Engine] Claim the singleton alternative for non-splittable aggregates
LantaoJin
committed
e471603
[Analytics Engine] Correct the SINGLE-alternative failure count and record the narrowing
LantaoJin
committed
0e9be71
[Analytics Engine] Make the hash-shuffle transport N-ary via slot-keyed buffers
LantaoJin
committed
1d3f3bb
[Analytics Engine] Add analytics.mpp.collapse_copartitioned_tiers to fuse co-partitioned join tiers
LantaoJin
committed
0415325
[Analytics Engine] Derive the broadcast join shape from a probe-shaped child and null out unbuildable enforcers
LantaoJin
committed
5831d80
[Analytics Engine] Keep a coordinator fetch above the gather for a bare LIMIT
LantaoJin
committed
659020b
[Analytics Engine] Update rule-profile and DAG-shape goldens for the deleted derive rule
LantaoJin
committed
8c7cb9d
[Analytics Engine] Assert broadcast-under-cascade on a mixed-key join where it is optimal
LantaoJin
committed
52812f3
[Analytics Engine] Record that the top-down suite is green and the residual failures were regressions
LantaoJin
committed
f5b3589

Commits on Aug 20, 2026

Commits on Aug 21, 2026

Commits on Aug 24, 2026

Commits on Aug 25, 2026

Commits on Aug 26, 2026

Commits on Aug 27, 2026

Stream hash-shuffle input instead of buffering the whole partition
LantaoJin
committed
ff3bc03

Commits on Aug 28, 2026

Commits on Aug 29, 2026

Commits on Aug 31, 2026

Commits on Sep 3, 2026

Commits on Sep 9, 2026

Commits on Sep 10, 2026

Commits on Sep 11, 2026