blob: df2a96e1ee0d573aadeb46bb6a36ceb093b697fc [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[$$24] |PARTITIONED|
7 {
8 -- AGGREGATE |LOCAL|
9 -- NESTED_TUPLE_SOURCE |LOCAL|
10 }
11 -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$24(ASC)] HASH:[$$24] |PARTITIONED|
12 -- PRE_CLUSTERED_GROUP_BY[$$16] |LOCAL|
13 {
14 -- AGGREGATE |LOCAL|
15 -- NESTED_TUPLE_SOURCE |LOCAL|
16 }
17 -- ONE_TO_ONE_EXCHANGE |LOCAL|
18 -- STABLE_SORT [$$16(ASC)] |LOCAL|
19 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
20 -- STREAM_PROJECT |PARTITIONED|
21 -- ASSIGN |PARTITIONED|
22 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
23 -- DATASOURCE_SCAN |PARTITIONED|
24 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
25 -- EMPTY_TUPLE_SOURCE |PARTITIONED|