-- SINK_WRITE  |UNPARTITIONED|
  -- STREAM_PROJECT  |UNPARTITIONED|
    -- ASSIGN  |UNPARTITIONED|
      -- STREAM_LIMIT  |UNPARTITIONED|
        -- SORT_MERGE_EXCHANGE [$$26(DESC) ]  |PARTITIONED|
          -- STREAM_LIMIT  |LOCAL|
            -- ONE_TO_ONE_EXCHANGE  |LOCAL|
              -- STABLE_SORT [$$26(DESC)]  |LOCAL|
                -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                  -- PRE_CLUSTERED_GROUP_BY[$$31]  |PARTITIONED|
                          {
                            -- AGGREGATE  |LOCAL|
                              -- NESTED_TUPLE_SOURCE  |LOCAL|
                          }
                          {
                            -- AGGREGATE  |LOCAL|
                              -- MICRO_PRE_CLUSTERED_GROUP_BY[$$32]  |LOCAL|
                                      {
                                        -- AGGREGATE  |LOCAL|
                                          -- NESTED_TUPLE_SOURCE  |LOCAL|
                                      }
                                -- NESTED_TUPLE_SOURCE  |LOCAL|
                          }
                    -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$31(ASC), $$32(ASC)] HASH:[$$31]  |PARTITIONED|
                      -- PRE_CLUSTERED_GROUP_BY[$$23, $$24]  |LOCAL|
                              {
                                -- AGGREGATE  |LOCAL|
                                  -- NESTED_TUPLE_SOURCE  |LOCAL|
                              }
                        -- ONE_TO_ONE_EXCHANGE  |LOCAL|
                          -- STABLE_SORT [$$23(ASC), $$24(ASC)]  |LOCAL|
                            -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                              -- STREAM_PROJECT  |PARTITIONED|
                                -- ASSIGN  |PARTITIONED|
                                  -- UNNEST  |PARTITIONED|
                                    -- ASSIGN  |PARTITIONED|
                                      -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                        -- DATASOURCE_SCAN  |PARTITIONED|
                                          -- ONE_TO_ONE_EXCHANGE  |PARTITIONED|
                                            -- EMPTY_TUPLE_SOURCE  |PARTITIONED|