local exchange (GATHER, SINGLE, [])
    remote exchange (GATHER, SINGLE, [])
        final hashaggregation over (channel$gid, groupid, i_brand_id$gid_1634, i_category_id$gid_1636, i_class_id$gid_1635)
            local exchange (REPARTITION, HASH, ["channel$gid", "groupid", "i_brand_id$gid_1634", "i_category_id$gid_1636", "i_class_id$gid_1635"])
                remote exchange (REPARTITION, HASH, ["channel$gid", "groupid", "i_brand_id$gid_1634", "i_category_id$gid_1636", "i_class_id$gid_1635"])
                    partial hashaggregation over (channel$gid, groupid, i_brand_id$gid_1634, i_category_id$gid_1636, i_class_id$gid_1635)
                        local exchange (REPARTITION, ROUND_ROBIN, [])
                            Filter
                                cross join:
                                    final hashaggregation over (i_brand_id, i_category_id, i_class_id)
                                        local exchange (GATHER, SINGLE, [])
                                            remote exchange (REPARTITION, HASH, ["i_brand_id", "i_category_id", "i_class_id"])
                                                partial hashaggregation over (i_brand_id, i_category_id, i_class_id)
                                                    Filter
                                                        semijoin (PARTITIONED):
                                                            remote exchange (REPARTITION, HASH, ["ss_item_sk"])
                                                                join (INNER, REPLICATED):
                                                                    join (INNER, REPLICATED):
                                                                        Filter
                                                                            scan store_sales
                                                                        local exchange (GATHER, SINGLE, [])
                                                                            remote exchange (REPLICATE, BROADCAST, [])
                                                                                Filter
                                                                                    scan date_dim
                                                                    local exchange (GATHER, SINGLE, [])
                                                                        remote exchange (REPLICATE, BROADCAST, [])
                                                                            Filter
                                                                                scan item
                                                            local exchange (GATHER, SINGLE, [])
                                                                remote exchange (REPARTITION, HASH, ["i_item_sk_1"])
                                                                    cte cross_items
                                                                        join (INNER, PARTITIONED):
                                                                            Filter
                                                                                final hashaggregation over (expr_207, expr_208, expr_209)
                                                                                    local exchange (REPARTITION, HASH, ["expr_207", "expr_208", "expr_209"])
                                                                                        remote exchange (REPARTITION, HASH, ["i_brand_id_53", "i_category_id_57", "i_class_id_55"])
                                                                                            partial hashaggregation over (i_brand_id_53, i_category_id_57, i_class_id_55)
                                                                                                join (INNER, REPLICATED):
                                                                                                    join (INNER, REPLICATED):
                                                                                                        Filter
                                                                                                            scan store_sales
                                                                                                        local exchange (GATHER, SINGLE, [])
                                                                                                            remote exchange (REPLICATE, BROADCAST, [])
                                                                                                                Filter
                                                                                                                    scan date_dim
                                                                                                    local exchange (GATHER, SINGLE, [])
                                                                                                        remote exchange (REPLICATE, BROADCAST, [])
                                                                                                            scan item
                                                                                        remote exchange (REPARTITION, HASH, ["i_brand_id_105", "i_category_id_109", "i_class_id_107"])
                                                                                            partial hashaggregation over (i_brand_id_105, i_category_id_109, i_class_id_107)
                                                                                                join (INNER, REPLICATED):
                                                                                                    join (INNER, REPLICATED):
                                                                                                        Filter
                                                                                                            scan catalog_sales
                                                                                                        local exchange (GATHER, SINGLE, [])
                                                                                                            remote exchange (REPLICATE, BROADCAST, [])
                                                                                                                Filter
                                                                                                                    scan date_dim
                                                                                                    local exchange (GATHER, SINGLE, [])
                                                                                                        remote exchange (REPLICATE, BROADCAST, [])
                                                                                                            scan item
                                                                                        remote exchange (REPARTITION, HASH, ["i_brand_id_161", "i_category_id_165", "i_class_id_163"])
                                                                                            partial hashaggregation over (i_brand_id_161, i_category_id_165, i_class_id_163)
                                                                                                join (INNER, REPLICATED):
                                                                                                    join (INNER, REPLICATED):
                                                                                                        Filter
                                                                                                            scan web_sales
                                                                                                        local exchange (GATHER, SINGLE, [])
                                                                                                            remote exchange (REPLICATE, BROADCAST, [])
                                                                                                                Filter
                                                                                                                    scan date_dim
                                                                                                    local exchange (GATHER, SINGLE, [])
                                                                                                        remote exchange (REPLICATE, BROADCAST, [])
                                                                                                            scan item
                                                                            local exchange (GATHER, SINGLE, [])
                                                                                remote exchange (REPARTITION, HASH, ["i_brand_id_8", "i_category_id_12", "i_class_id_10"])
                                                                                    scan item
                                    local exchange (GATHER, SINGLE, [])
                                        remote exchange (REPLICATE, BROADCAST, [])
                                            local exchange (GATHER, SINGLE, [])
                                                remote exchange (GATHER, SINGLE, [])
                                                    cte avg_sales
                                                        final hashaggregation over ()
                                                            local exchange (GATHER, SINGLE, [])
                                                                remote exchange (GATHER, SINGLE, [])
                                                                    partial hashaggregation over ()
                                                                        join (INNER, REPLICATED):
                                                                            Filter
                                                                                scan store_sales
                                                                            local exchange (GATHER, SINGLE, [])
                                                                                remote exchange (REPLICATE, BROADCAST, [])
                                                                                    Filter
                                                                                        scan date_dim
                                                                    partial hashaggregation over ()
                                                                        join (INNER, REPLICATED):
                                                                            Filter
                                                                                scan catalog_sales
                                                                            local exchange (GATHER, SINGLE, [])
                                                                                remote exchange (REPLICATE, BROADCAST, [])
                                                                                    Filter
                                                                                        scan date_dim
                                                                    partial hashaggregation over ()
                                                                        join (INNER, REPLICATED):
                                                                            Filter
                                                                                scan web_sales
                                                                            local exchange (GATHER, SINGLE, [])
                                                                                remote exchange (REPLICATE, BROADCAST, [])
                                                                                    Filter
                                                                                        scan date_dim
                            Filter
                                cross join:
                                    final hashaggregation over (i_brand_id_474, i_category_id_478, i_class_id_476)
                                        local exchange (GATHER, SINGLE, [])
                                            remote exchange (REPARTITION, HASH, ["i_brand_id_474", "i_category_id_478", "i_class_id_476"])
                                                partial hashaggregation over (i_brand_id_474, i_category_id_478, i_class_id_476)
                                                    Filter
                                                        semijoin (PARTITIONED):
                                                            remote exchange (REPARTITION, HASH, ["cs_item_sk_448"])
                                                                join (INNER, REPLICATED):
                                                                    join (INNER, REPLICATED):
                                                                        Filter
                                                                            scan catalog_sales
                                                                        local exchange (GATHER, SINGLE, [])
                                                                            remote exchange (REPLICATE, BROADCAST, [])
                                                                                Filter
                                                                                    scan date_dim
                                                                    local exchange (GATHER, SINGLE, [])
                                                                        remote exchange (REPLICATE, BROADCAST, [])
                                                                            Filter
                                                                                scan item
                                                            local exchange (GATHER, SINGLE, [])
                                                                remote exchange (REPARTITION, HASH, ["i_item_sk_518"])
                                                                    cte cross_items
                                                                        join (INNER, PARTITIONED):
                                                                            Filter
                                                                                final hashaggregation over (expr_793, expr_794, expr_795)
                                                                                    local exchange (REPARTITION, HASH, ["expr_793", "expr_794", "expr_795"])
                                                                                        remote exchange (REPARTITION, HASH, ["i_brand_id_570", "i_category_id_574", "i_class_id_572"])
                                                                                            partial hashaggregation over (i_brand_id_570, i_category_id_574, i_class_id_572)
                                                                                                join (INNER, REPLICATED):
                                                                                                    join (INNER, REPLICATED):
                                                                                                        Filter
                                                                                                            scan store_sales
                                                                                                        local exchange (GATHER, SINGLE, [])
                                                                                                            remote exchange (REPLICATE, BROADCAST, [])
                                                                                                                Filter
                                                                                                                    scan date_dim
                                                                                                    local exchange (GATHER, SINGLE, [])
                                                                                                        remote exchange (REPLICATE, BROADCAST, [])
                                                                                                            scan item
                                                                                        remote exchange (REPARTITION, HASH, ["i_brand_id_657", "i_category_id_661", "i_class_id_659"])
                                                                                            partial hashaggregation over (i_brand_id_657, i_category_id_661, i_class_id_659)
                                                                                                join (INNER, REPLICATED):
                                                                                                    join (INNER, REPLICATED):
                                                                                                        Filter
                                                                                                            scan catalog_sales
                                                                                                        local exchange (GATHER, SINGLE, [])
                                                                                                            remote exchange (REPLICATE, BROADCAST, [])
                                                                                                                Filter
                                                                                                                    scan date_dim
                                                                                                    local exchange (GATHER, SINGLE, [])
                                                                                                        remote exchange (REPLICATE, BROADCAST, [])
                                                                                                            scan item
                                                                                        remote exchange (REPARTITION, HASH, ["i_brand_id_747", "i_category_id_751", "i_class_id_749"])
                                                                                            partial hashaggregation over (i_brand_id_747, i_category_id_751, i_class_id_749)
                                                                                                join (INNER, REPLICATED):
                                                                                                    join (INNER, REPLICATED):
                                                                                                        Filter
                                                                                                            scan web_sales
                                                                                                        local exchange (GATHER, SINGLE, [])
                                                                                                            remote exchange (REPLICATE, BROADCAST, [])
                                                                                                                Filter
                                                                                                                    scan date_dim
                                                                                                    local exchange (GATHER, SINGLE, [])
                                                                                                        remote exchange (REPLICATE, BROADCAST, [])
                                                                                                            scan item
                                                                            local exchange (GATHER, SINGLE, [])
                                                                                remote exchange (REPARTITION, HASH, ["i_brand_id_525", "i_category_id_529", "i_class_id_527"])
                                                                                    scan item
                                    local exchange (GATHER, SINGLE, [])
                                        remote exchange (REPLICATE, BROADCAST, [])
                                            local exchange (GATHER, SINGLE, [])
                                                remote exchange (GATHER, SINGLE, [])
                                                    cte avg_sales
                                                        final hashaggregation over ()
                                                            local exchange (GATHER, SINGLE, [])
                                                                remote exchange (GATHER, SINGLE, [])
                                                                    partial hashaggregation over ()
                                                                        join (INNER, REPLICATED):
                                                                            Filter
                                                                                scan store_sales
                                                                            local exchange (GATHER, SINGLE, [])
                                                                                remote exchange (REPLICATE, BROADCAST, [])
                                                                                    Filter
                                                                                        scan date_dim
                                                                    partial hashaggregation over ()
                                                                        join (INNER, REPLICATED):
                                                                            Filter
                                                                                scan catalog_sales
                                                                            local exchange (GATHER, SINGLE, [])
                                                                                remote exchange (REPLICATE, BROADCAST, [])
                                                                                    Filter
                                                                                        scan date_dim
                                                                    partial hashaggregation over ()
                                                                        join (INNER, REPLICATED):
                                                                            Filter
                                                                                scan web_sales
                                                                            local exchange (GATHER, SINGLE, [])
                                                                                remote exchange (REPLICATE, BROADCAST, [])
                                                                                    Filter
                                                                                        scan date_dim
                            Filter
                                cross join:
                                    final hashaggregation over (i_brand_id_1067, i_category_id_1071, i_class_id_1069)
                                        local exchange (GATHER, SINGLE, [])
                                            remote exchange (REPARTITION, HASH, ["i_brand_id_1067", "i_category_id_1071", "i_class_id_1069"])
                                                partial hashaggregation over (i_brand_id_1067, i_category_id_1071, i_class_id_1069)
                                                    Filter
                                                        semijoin (PARTITIONED):
                                                            remote exchange (REPARTITION, HASH, ["ws_item_sk_1029"])
                                                                join (INNER, REPLICATED):
                                                                    join (INNER, REPLICATED):
                                                                        Filter
                                                                            scan web_sales
                                                                        local exchange (GATHER, SINGLE, [])
                                                                            remote exchange (REPLICATE, BROADCAST, [])
                                                                                Filter
                                                                                    scan date_dim
                                                                    local exchange (GATHER, SINGLE, [])
                                                                        remote exchange (REPLICATE, BROADCAST, [])
                                                                            Filter
                                                                                scan item
                                                            local exchange (GATHER, SINGLE, [])
                                                                remote exchange (REPARTITION, HASH, ["i_item_sk_1111"])
                                                                    cte cross_items
                                                                        join (INNER, PARTITIONED):
                                                                            Filter
                                                                                final hashaggregation over (expr_1386, expr_1387, expr_1388)
                                                                                    local exchange (REPARTITION, HASH, ["expr_1386", "expr_1387", "expr_1388"])
                                                                                        remote exchange (REPARTITION, HASH, ["i_brand_id_1163", "i_category_id_1167", "i_class_id_1165"])
                                                                                            partial hashaggregation over (i_brand_id_1163, i_category_id_1167, i_class_id_1165)
                                                                                                join (INNER, REPLICATED):
                                                                                                    join (INNER, REPLICATED):
                                                                                                        Filter
                                                                                                            scan store_sales
                                                                                                        local exchange (GATHER, SINGLE, [])
                                                                                                            remote exchange (REPLICATE, BROADCAST, [])
                                                                                                                Filter
                                                                                                                    scan date_dim
                                                                                                    local exchange (GATHER, SINGLE, [])
                                                                                                        remote exchange (REPLICATE, BROADCAST, [])
                                                                                                            scan item
                                                                                        remote exchange (REPARTITION, HASH, ["i_brand_id_1250", "i_category_id_1254", "i_class_id_1252"])
                                                                                            partial hashaggregation over (i_brand_id_1250, i_category_id_1254, i_class_id_1252)
                                                                                                join (INNER, REPLICATED):
                                                                                                    join (INNER, REPLICATED):
                                                                                                        Filter
                                                                                                            scan catalog_sales
                                                                                                        local exchange (GATHER, SINGLE, [])
                                                                                                            remote exchange (REPLICATE, BROADCAST, [])
                                                                                                                Filter
                                                                                                                    scan date_dim
                                                                                                    local exchange (GATHER, SINGLE, [])
                                                                                                        remote exchange (REPLICATE, BROADCAST, [])
                                                                                                            scan item
                                                                                        remote exchange (REPARTITION, HASH, ["i_brand_id_1340", "i_category_id_1344", "i_class_id_1342"])
                                                                                            partial hashaggregation over (i_brand_id_1340, i_category_id_1344, i_class_id_1342)
                                                                                                join (INNER, REPLICATED):
                                                                                                    join (INNER, REPLICATED):
                                                                                                        Filter
                                                                                                            scan web_sales
                                                                                                        local exchange (GATHER, SINGLE, [])
                                                                                                            remote exchange (REPLICATE, BROADCAST, [])
                                                                                                                Filter
                                                                                                                    scan date_dim
                                                                                                    local exchange (GATHER, SINGLE, [])
                                                                                                        remote exchange (REPLICATE, BROADCAST, [])
                                                                                                            scan item
                                                                            local exchange (GATHER, SINGLE, [])
                                                                                remote exchange (REPARTITION, HASH, ["i_brand_id_1118", "i_category_id_1122", "i_class_id_1120"])
                                                                                    scan item
                                    local exchange (GATHER, SINGLE, [])
                                        remote exchange (REPLICATE, BROADCAST, [])
                                            local exchange (GATHER, SINGLE, [])
                                                remote exchange (GATHER, SINGLE, [])
                                                    cte avg_sales
                                                        final hashaggregation over ()
                                                            local exchange (GATHER, SINGLE, [])
                                                                remote exchange (GATHER, SINGLE, [])
                                                                    partial hashaggregation over ()
                                                                        join (INNER, REPLICATED):
                                                                            Filter
                                                                                scan store_sales
                                                                            local exchange (GATHER, SINGLE, [])
                                                                                remote exchange (REPLICATE, BROADCAST, [])
                                                                                    Filter
                                                                                        scan date_dim
                                                                    partial hashaggregation over ()
                                                                        join (INNER, REPLICATED):
                                                                            Filter
                                                                                scan catalog_sales
                                                                            local exchange (GATHER, SINGLE, [])
                                                                                remote exchange (REPLICATE, BROADCAST, [])
                                                                                    Filter
                                                                                        scan date_dim
                                                                    partial hashaggregation over ()
                                                                        join (INNER, REPLICATED):
                                                                            Filter
                                                                                scan web_sales
                                                                            local exchange (GATHER, SINGLE, [])
                                                                                remote exchange (REPLICATE, BROADCAST, [])
                                                                                    Filter
                                                                                        scan date_dim
