blob: f96a70e6412090492b72586186354e10a4ac0e83 [file] [log] [blame]
vinayakb38b7ca42012-03-05 05:44:15 +00001-- SINK_WRITE |PARTITIONED|
2 -- RANDOM_MERGE_EXCHANGE |PARTITIONED|
3 -- STREAM_PROJECT |PARTITIONED|
4 -- STREAM_SELECT |PARTITIONED|
5 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
6 -- PRE_SORTED_GROUP_BY[$$0] |PARTITIONED|
7 {
8 -- AGGREGATE |LOCAL|
9 -- STREAM_SELECT |LOCAL|
10 -- NESTED_TUPLE_SOURCE |LOCAL|
11 }
12 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
13 -- STABLE_SORT [$$0(ASCENDING)] |PARTITIONED|
14 -- HASH_PARTITION_EXCHANGE [$$0] |PARTITIONED|
15 -- STREAM_PROJECT |PARTITIONED|
16 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
17 -- NESTED_LOOP_BCAST_JOIN |PARTITIONED|
18 -- BROADCAST_EXCHANGE |PARTITIONED|
19 -- ASSIGN |PARTITIONED|
20 -- AQL_DATASET_UNNEST |PARTITIONED|
21 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
22 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
23 -- ASSIGN |PARTITIONED|
24 -- AQL_DATASET_UNNEST |PARTITIONED|
25 -- EMPTY_TUPLE_SOURCE |PARTITIONED|