blob: 3042fae879e73d2a873e3127f7c04d99b15a4482 [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[$$23] |PARTITIONED|
7 {
8 -- AGGREGATE |LOCAL|
9 -- STREAM_SELECT |LOCAL|
10 -- NESTED_TUPLE_SOURCE |LOCAL|
11 }
12 -- ONE_TO_ONE_EXCHANGE |LOCAL|
13 -- STABLE_SORT [$$23(ASC), $$7(ASC)] |LOCAL|
14 -- HASH_PARTITION_EXCHANGE [$$23] |PARTITIONED|
15 -- STREAM_PROJECT |PARTITIONED|
16 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
17 -- HYBRID_HASH_JOIN [$$2][$$7] |PARTITIONED|
18 -- HASH_PARTITION_EXCHANGE [$$2] |PARTITIONED|
19 -- STREAM_PROJECT |PARTITIONED|
20 -- UNNEST |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|
26 -- HASH_PARTITION_EXCHANGE [$$7] |PARTITIONED|
27 -- RUNNING_AGGREGATE |PARTITIONED|
28 -- STREAM_PROJECT |PARTITIONED|
29 -- SORT_MERGE_EXCHANGE [$$24(DESC) ] |PARTITIONED|
30 -- STABLE_SORT [$$24(DESC)] |LOCAL|
31 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
32 -- PRE_CLUSTERED_GROUP_BY[$$30] |PARTITIONED|
33 {
34 -- AGGREGATE |LOCAL|
35 -- NESTED_TUPLE_SOURCE |LOCAL|
36 }
37 -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$30(ASC)] HASH:[$$30] |PARTITIONED|
38 -- PRE_CLUSTERED_GROUP_BY[$$6] |LOCAL|
39 {
40 -- AGGREGATE |LOCAL|
41 -- NESTED_TUPLE_SOURCE |LOCAL|
42 }
43 -- ONE_TO_ONE_EXCHANGE |LOCAL|
44 -- STABLE_SORT [$$6(ASC)] |LOCAL|
45 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
46 -- STREAM_PROJECT |PARTITIONED|
47 -- UNNEST |PARTITIONED|
48 -- ASSIGN |PARTITIONED|
49 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
50 -- DATASOURCE_SCAN |PARTITIONED|
51 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
52 -- EMPTY_TUPLE_SOURCE |PARTITIONED|