local exchange (GATHER, SINGLE, [])
    remote exchange (GATHER, SINGLE, [])
        final hashaggregation over (concat_251, d_year_252, w_city_247, w_country_250, w_county_248, w_state_249, w_warehouse_name_245, w_warehouse_sq_ft_246)
            local exchange (REPARTITION, HASH, ["concat_251", "d_year_252", "w_city_247", "w_country_250", "w_county_248", "w_state_249", "w_warehouse_name_245", "w_warehouse_sq_ft_246"])
                partial hashaggregation over (concat_472, d_year, w_city, w_country, w_county, w_state, w_warehouse_name, w_warehouse_sq_ft)
                    final hashaggregation over (d_year, w_city, w_country, w_county, w_state, w_warehouse_name, w_warehouse_sq_ft)
                        local exchange (GATHER, SINGLE, [])
                            remote exchange (REPARTITION, HASH, ["d_year", "w_city", "w_country", "w_county", "w_state", "w_warehouse_name", "w_warehouse_sq_ft"])
                                partial hashaggregation over (d_year, w_city, w_country, w_county, w_state, w_warehouse_name, w_warehouse_sq_ft)
                                    join (INNER, REPLICATED):
                                        join (INNER, PARTITIONED):
                                            remote exchange (REPARTITION, HASH, ["t_time_sk"])
                                                scan time_dim
                                            local exchange (GATHER, SINGLE, [])
                                                remote exchange (REPARTITION, HASH, ["ws_sold_time_sk"])
                                                    join (INNER, PARTITIONED):
                                                        remote exchange (REPARTITION, HASH, ["ws_sold_date_sk"])
                                                            join (INNER, REPLICATED):
                                                                scan web_sales
                                                                local exchange (GATHER, SINGLE, [])
                                                                    remote exchange (REPLICATE, BROADCAST, [])
                                                                        scan ship_mode
                                                        local exchange (GATHER, SINGLE, [])
                                                            remote exchange (REPARTITION, HASH, ["d_date_sk"])
                                                                ReuseTableScan date_dim (Consumer)
                                        local exchange (GATHER, SINGLE, [])
                                            remote exchange (REPLICATE, BROADCAST, [])
                                                scan warehouse
                partial hashaggregation over (concat_515, d_year_110, w_city_97, w_country_101, w_county_98, w_state_99, w_warehouse_name_91, w_warehouse_sq_ft_92)
                    final hashaggregation over (d_year_110, w_city_97, w_country_101, w_county_98, w_state_99, w_warehouse_name_91, w_warehouse_sq_ft_92)
                        local exchange (GATHER, SINGLE, [])
                            remote exchange (REPARTITION, HASH, ["d_year_110", "w_city_97", "w_country_101", "w_county_98", "w_state_99", "w_warehouse_name_91", "w_warehouse_sq_ft_92"])
                                partial hashaggregation over (d_year_110, w_city_97, w_country_101, w_county_98, w_state_99, w_warehouse_name_91, w_warehouse_sq_ft_92)
                                    join (INNER, REPLICATED):
                                        join (INNER, PARTITIONED):
                                            remote exchange (REPARTITION, HASH, ["t_time_sk_133"])
                                                scan time_dim
                                            local exchange (GATHER, SINGLE, [])
                                                remote exchange (REPARTITION, HASH, ["cs_sold_time_sk"])
                                                    join (INNER, REPLICATED):
                                                        join (INNER, REPLICATED):
                                                            scan catalog_sales
                                                            local exchange (GATHER, SINGLE, [])
                                                                remote exchange (REPLICATE, BROADCAST, [])
                                                                    scan ship_mode
                                                        local exchange (GATHER, SINGLE, [])
                                                            remote exchange (REPLICATE, BROADCAST, [])
                                                                ReuseTableScan date_dim (Producer)
                                        local exchange (GATHER, SINGLE, [])
                                            remote exchange (REPLICATE, BROADCAST, [])
                                                scan warehouse
