-- DISTRIBUTE_RESULT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- PRE_CLUSTERED_GROUP_BY[$$21] |PARTITIONED| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- STREAM_SELECT |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STABLE_SORT [$$21(ASC), $$item(ASC)] |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$21] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- HYBRID_HASH_JOIN [$$lottery_number][$$item] |PARTITIONED| | |
-- HASH_PARTITION_EXCHANGE [$$lottery_number] |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- UNNEST |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 [$$item] |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- RUNNING_AGGREGATE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- SORT_MERGE_EXCHANGE [$$23(DESC) ] |PARTITIONED| | |
-- STABLE_SORT [$$23(DESC)] |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- SORT_GROUP_BY[$$30] |PARTITIONED| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- HASH_PARTITION_EXCHANGE [$$30] |PARTITIONED| | |
-- SORT_GROUP_BY[$$lottery_number] |PARTITIONED| | |
{ | |
-- AGGREGATE |LOCAL| | |
-- NESTED_TUPLE_SOURCE |LOCAL| | |
} | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- UNNEST |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ASSIGN |PARTITIONED| | |
-- STREAM_PROJECT |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- DATASOURCE_SCAN |PARTITIONED| | |
-- ONE_TO_ONE_EXCHANGE |PARTITIONED| | |
-- EMPTY_TUPLE_SOURCE |PARTITIONED| |