blob: 4f1d53f383edf97b0734f38bc07b666c8007183f [file] [log] [blame]
vinayakb38b7ca42012-03-05 05:44:15 +00001-- SINK_WRITE |PARTITIONED|
2 -- RANDOM_MERGE_EXCHANGE |PARTITIONED|
3 -- STREAM_PROJECT |PARTITIONED|
4 -- ASSIGN |PARTITIONED|
5 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
6 -- PRE_CLUSTERED_GROUP_BY[$$14] |PARTITIONED|
7 {
8 -- AGGREGATE |LOCAL|
9 -- NESTED_TUPLE_SOURCE |LOCAL|
10 }
11 -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$14(ASC)] HASH:[$$14] |PARTITIONED|
12 -- PRE_CLUSTERED_GROUP_BY[$$4] |LOCAL|
13 {
14 -- AGGREGATE |LOCAL|
15 -- NESTED_TUPLE_SOURCE |LOCAL|
16 }
17 -- ONE_TO_ONE_EXCHANGE |LOCAL|
18 -- STABLE_SORT [$$4(ASC)] |LOCAL|
19 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
20 -- STREAM_PROJECT |PARTITIONED|
21 -- UNNEST |PARTITIONED|
22 -- ASSIGN |PARTITIONED|
23 -- ASSIGN |PARTITIONED|
24 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
25 -- DATASOURCE_SCAN |PARTITIONED|
26 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
27 -- EMPTY_TUPLE_SOURCE |PARTITIONED|