| -- SINK_WRITE |PARTITIONED| | |
| -- RANDOM_MERGE_EXCHANGE |PARTITIONED| | |
| -- STREAM_PROJECT |PARTITIONED| | |
| -- ASSIGN |PARTITIONED| | |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
| -- PRE_CLUSTERED_GROUP_BY[$$42] |PARTITIONED| | |
| { | |
| -- AGGREGATE |LOCAL| | |
| -- MICRO_PRE_CLUSTERED_GROUP_BY[$$40] |LOCAL| | |
| { | |
| -- AGGREGATE |LOCAL| | |
| -- MICRO_PRE_CLUSTERED_GROUP_BY[$$37, $$38] |LOCAL| | |
| { | |
| -- AGGREGATE |LOCAL| | |
| -- STREAM_SELECT |LOCAL| | |
| -- NESTED_TUPLE_SOURCE |LOCAL| | |
| } | |
| -- IN_MEMORY_STABLE_SORT [$$37(ASC), $$38(ASC)] |LOCAL| | |
| -- STREAM_SELECT |LOCAL| | |
| -- NESTED_TUPLE_SOURCE |LOCAL| | |
| } | |
| -- IN_MEMORY_STABLE_SORT [$$40(ASC), $$38(ASC)] |LOCAL| | |
| -- STREAM_SELECT |LOCAL| | |
| -- NESTED_TUPLE_SOURCE |LOCAL| | |
| } | |
| -- ONE_TO_ONE_EXCHANGE |LOCAL| | |
| -- STABLE_SORT [$$42(ASC), $$40(ASC)] |LOCAL| | |
| -- HASH_PARTITION_EXCHANGE [$$42] |PARTITIONED| | |
| -- STREAM_PROJECT |PARTITIONED| | |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
| -- HYBRID_HASH_JOIN [$$48, $$50][$$34, $$35] |PARTITIONED| | |
| -- HASH_PARTITION_EXCHANGE [$$48, $$50] |PARTITIONED| | |
| -- HYBRID_HASH_JOIN [$$40][$$37] |PARTITIONED| | |
| -- HASH_PARTITION_EXCHANGE [$$40] |PARTITIONED| | |
| -- STREAM_PROJECT |PARTITIONED| | |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
| -- HYBRID_HASH_JOIN [$$42][$$43] |PARTITIONED| | |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
| -- DATASOURCE_SCAN |PARTITIONED| | |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
| -- EMPTY_TUPLE_SOURCE |PARTITIONED| | |
| -- HASH_PARTITION_EXCHANGE [$$43] |PARTITIONED| | |
| -- ASSIGN |PARTITIONED| | |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
| -- DATASOURCE_SCAN |PARTITIONED| | |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
| -- EMPTY_TUPLE_SOURCE |PARTITIONED| | |
| -- HASH_PARTITION_EXCHANGE [$$37] |PARTITIONED| | |
| -- ASSIGN |PARTITIONED| | |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
| -- DATASOURCE_SCAN |PARTITIONED| | |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
| -- EMPTY_TUPLE_SOURCE |PARTITIONED| | |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
| -- ASSIGN |PARTITIONED| | |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
| -- DATASOURCE_SCAN |PARTITIONED| | |
| -- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
| -- EMPTY_TUPLE_SOURCE |PARTITIONED| |