blob: c8eb36864cb4515536b948de9ee4158e31491d26 [file] [log] [blame]
vinayakb38b7ca42012-03-05 05:44:15 +00001-- SINK_WRITE |UNPARTITIONED|
2 -- STREAM_PROJECT |UNPARTITIONED|
3 -- ASSIGN |UNPARTITIONED|
4 -- STREAM_LIMIT |UNPARTITIONED|
alexander.behm905948b2012-12-06 09:06:45 +00005 -- STREAM_PROJECT |PARTITIONED|
6 -- SORT_MERGE_EXCHANGE [$$26(DESC) ] |PARTITIONED|
7 -- STREAM_LIMIT |PARTITIONED|
8 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
9 -- STABLE_SORT [$$26(DESC)] |PARTITIONED|
10 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
11 -- PRE_CLUSTERED_GROUP_BY[$$32] |PARTITIONED|
12 {
13 -- AGGREGATE |LOCAL|
vinayakb38b7ca42012-03-05 05:44:15 +000014 -- NESTED_TUPLE_SOURCE |LOCAL|
alexander.behm905948b2012-12-06 09:06:45 +000015 }
16 {
17 -- AGGREGATE |LOCAL|
18 -- MICRO_PRE_CLUSTERED_GROUP_BY[$$33] |LOCAL|
19 {
20 -- AGGREGATE |LOCAL|
21 -- NESTED_TUPLE_SOURCE |LOCAL|
22 }
vinayakb38b7ca42012-03-05 05:44:15 +000023 -- NESTED_TUPLE_SOURCE |LOCAL|
alexander.behm905948b2012-12-06 09:06:45 +000024 }
25 -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$32(ASC), $$33(ASC)] HASH:[$$32] |PARTITIONED|
26 -- PRE_CLUSTERED_GROUP_BY[$$23, $$24] |PARTITIONED|
27 {
28 -- AGGREGATE |LOCAL|
29 -- NESTED_TUPLE_SOURCE |LOCAL|
30 }
31 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
32 -- STABLE_SORT [$$23(ASC), $$24(ASC)] |PARTITIONED|
33 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
34 -- STREAM_PROJECT |PARTITIONED|
35 -- ASSIGN |PARTITIONED|
36 -- STREAM_PROJECT |PARTITIONED|
37 -- UNNEST |PARTITIONED|
38 -- STREAM_PROJECT |PARTITIONED|
39 -- ASSIGN |PARTITIONED|
40 -- STREAM_PROJECT |PARTITIONED|
41 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
42 -- DATASOURCE_SCAN |PARTITIONED|
43 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
44 -- EMPTY_TUPLE_SOURCE |PARTITIONED|