-- SINK_WRITE  |UNPARTITIONED|
  -- STREAM_PROJECT  |UNPARTITIONED|
    -- ASSIGN  |UNPARTITIONED|
      -- STREAM_LIMIT  |UNPARTITIONED|
        -- SORT_MERGE_EXCHANGE [$$12(DESC), $$11(ASC) ]  |PARTITIONED|
          -- STREAM_LIMIT  |LOCAL|
            -- ONE_TO_ONE_EXCHANGE  |LOCAL|
              -- STABLE_SORT [$$12(DESC), $$11(ASC)]  |LOCAL|
                -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                  -- PRE_CLUSTERED_GROUP_BY[$$72, $$73]  |PARTITIONED|
                          {
                            -- AGGREGATE  |LOCAL|
                              -- NESTED_TUPLE_SOURCE  |LOCAL|
                          }
                    -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$72(ASC), $$73(ASC)] HASH:[$$72, $$73]  |PARTITIONED|
                      -- PRE_CLUSTERED_GROUP_BY[$$56, $$57]  |LOCAL|
                              {
                                -- AGGREGATE  |LOCAL|
                                  -- NESTED_TUPLE_SOURCE  |LOCAL|
                              }
                        -- ONE_TO_ONE_EXCHANGE  |LOCAL|
                          -- STABLE_SORT [$$56(ASC), $$57(ASC)]  |LOCAL|
                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                              -- STREAM_PROJECT  |PARTITIONED|
                                -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                  -- HYBRID_HASH_JOIN [$$57][$$60]  |PARTITIONED|
                                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                      -- STREAM_PROJECT  |PARTITIONED|
                                        -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                          -- HYBRID_HASH_JOIN [$$57][$$4]  |PARTITIONED|
                                            -- HASH_PARTITION_EXCHANGE [$$57]  |PARTITIONED|
                                              -- STREAM_PROJECT  |PARTITIONED|
                                                -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                                  -- HYBRID_HASH_JOIN [$$56][$$64]  |PARTITIONED|
                                                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                                      -- STREAM_PROJECT  |PARTITIONED|
                                                        -- ASSIGN  |PARTITIONED|
                                                          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                                            -- DATASOURCE_SCAN  |PARTITIONED|
                                                              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                                                -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
                                                    -- HASH_PARTITION_EXCHANGE [$$64]  |PARTITIONED|
                                                      -- STREAM_PROJECT  |PARTITIONED|
                                                        -- ASSIGN  |PARTITIONED|
                                                          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                                            -- DATASOURCE_SCAN  |PARTITIONED|
                                                              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                                                -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
                                            -- HASH_PARTITION_EXCHANGE [$$4]  |PARTITIONED|
                                              -- STREAM_PROJECT  |PARTITIONED|
                                                -- STREAM_SELECT  |PARTITIONED|
                                                  -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                                    -- PRE_CLUSTERED_GROUP_BY[$$69]  |PARTITIONED|
                                                            {
                                                              -- AGGREGATE  |LOCAL|
                                                                -- NESTED_TUPLE_SOURCE  |LOCAL|
                                                            }
                                                      -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$69(ASC)] HASH:[$$69]  |PARTITIONED|
                                                        -- PRE_CLUSTERED_GROUP_BY[$$58]  |LOCAL|
                                                                {
                                                                  -- AGGREGATE  |LOCAL|
                                                                    -- NESTED_TUPLE_SOURCE  |LOCAL|
                                                                }
                                                          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                                            -- SPLIT  |PARTITIONED|
                                                              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                                                -- STREAM_PROJECT  |PARTITIONED|
                                                                  -- ASSIGN  |PARTITIONED|
                                                                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                                                      -- DATASOURCE_SCAN  |PARTITIONED|
                                                                        -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                                                          -- EMPTY_TUPLE_SOURCE  |PARTITIONED|
                                    -- HASH_PARTITION_EXCHANGE [$$60]  |PARTITIONED|
                                      -- STREAM_PROJECT  |UNPARTITIONED|
                                        -- ASSIGN  |UNPARTITIONED|
                                          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                            -- SPLIT  |PARTITIONED|
                                              -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                                -- STREAM_PROJECT  |PARTITIONED|
                                                  -- ASSIGN  |PARTITIONED|
                                                    -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                                      -- DATASOURCE_SCAN  |PARTITIONED|
                                                        -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                                          -- EMPTY_TUPLE_SOURCE  |PARTITIONED|