-- SINK_WRITE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- SORT_MERGE_EXCHANGE [$$89(DESC) ] |PARTITIONED| | |
-- STABLE_SORT [$$89(DESC)] |LOCAL| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- EXTERNAL_GROUP_BY[$$120] |PARTITIONED| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- HASH_PARTITION_EXCHANGE [$$120] |PARTITIONED| | |
-- EXTERNAL_GROUP_BY[$$94] |LOCAL| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$81, $$115][$$112, $$88] |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 [$$112] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$82][$$83] |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- STREAM_SELECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- DATASOURCE_SCAN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- EMPTY_TUPLE_SOURCE |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$83] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$99][$$85] |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$99] |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 [$$85] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$88][$$86] |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$88] |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 [$$86] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$92][$$87] |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$92] |PARTITIONED| | |
-- STREAM_PROJECT |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| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- STREAM_SELECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- DATASOURCE_SCAN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- EMPTY_TUPLE_SOURCE |PARTITIONED| |