-- 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[$$73, $$74] |PARTITIONED| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$73(ASC), $$74(ASC)] HASH:[$$73, $$74] |PARTITIONED| | |
-- PRE_CLUSTERED_GROUP_BY[$$54, $$55] |LOCAL| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- ONE_TO_ONE_EXCHANGE |LOCAL| | |
-- STABLE_SORT [$$54(ASC), $$55(ASC)] |LOCAL| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$55][$$58] |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$55][$$4] |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$55] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$54][$$63] |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 [$$63] |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[$$70] |PARTITIONED| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$70(ASC)] HASH:[$$70] |PARTITIONED| | |
-- PRE_CLUSTERED_GROUP_BY[$$56] |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 [$$58] |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| |