-- DISTRIBUTE_RESULT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- SORT_MERGE_EXCHANGE [$#2(DESC) ] |PARTITIONED| | |
-- STABLE_SORT [$#2(DESC)] |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- SORT_GROUP_BY[$$291] |PARTITIONED| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- HASH_PARTITION_EXCHANGE [$$291] |PARTITIONED| | |
-- SORT_GROUP_BY[$$275] |PARTITIONED| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$257][$$256] |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$257] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- STREAM_SELECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- DATASOURCE_SCAN (test.region) |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- EMPTY_TUPLE_SOURCE |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$256] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$274, $$268][$$266, $$269] |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$274, $$268] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$258][$$274] |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$258] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$260, $$254, $$263][$$276, $$277, $$278] |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$260, $$254, $$263] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$245, $$246][$$254, $$281] |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$245, $$246] |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- DATASOURCE_SCAN (test.stock) |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- EMPTY_TUPLE_SOURCE |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$254, $$281] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- UNNEST |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- STREAM_SELECT |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- DATASOURCE_SCAN (test.orders) |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- EMPTY_TUPLE_SOURCE |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$276, $$277, $$278] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- DATASOURCE_SCAN (test.customer) |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- EMPTY_TUPLE_SOURCE |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$274] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- DATASOURCE_SCAN (test.nation) |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- EMPTY_TUPLE_SOURCE |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$266, $$269] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- DATASOURCE_SCAN (test.supplier) |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- EMPTY_TUPLE_SOURCE |PARTITIONED| |