blob: c542f9787c5c5522d9ce889d071836639af3bdcc [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|
alexander.behm905948b2012-12-06 09:06:45 +00005 -- STREAM_PROJECT |PARTITIONED|
6 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
7 -- PRE_CLUSTERED_GROUP_BY[$$25] |PARTITIONED|
8 {
9 -- AGGREGATE |LOCAL|
10 -- MICRO_PRE_CLUSTERED_GROUP_BY[$$23] |LOCAL|
11 {
12 -- AGGREGATE |LOCAL|
13 -- STREAM_SELECT |LOCAL|
14 -- NESTED_TUPLE_SOURCE |LOCAL|
15 }
16 -- STREAM_SELECT |LOCAL|
17 -- NESTED_TUPLE_SOURCE |LOCAL|
18 }
19 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
20 -- STABLE_SORT [$$25(ASC), $$23(ASC)] |PARTITIONED|
21 -- HASH_PARTITION_EXCHANGE [$$25] |PARTITIONED|
22 -- STREAM_PROJECT |PARTITIONED|
23 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
24 -- HYBRID_HASH_JOIN [$$23][$$20] |PARTITIONED|
25 -- HASH_PARTITION_EXCHANGE [$$23] |PARTITIONED|
26 -- STREAM_PROJECT |PARTITIONED|
27 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
28 -- HYBRID_HASH_JOIN [$$25][$$26] |PARTITIONED|
29 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
30 -- DATASOURCE_SCAN |PARTITIONED|
31 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
32 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
33 -- HASH_PARTITION_EXCHANGE [$$26] |PARTITIONED|
34 -- ASSIGN |PARTITIONED|
35 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
36 -- DATASOURCE_SCAN |PARTITIONED|
37 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
38 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
39 -- HASH_PARTITION_EXCHANGE [$$20] |PARTITIONED|
40 -- ASSIGN |PARTITIONED|
41 -- STREAM_PROJECT |PARTITIONED|
vinayakb38b7ca42012-03-05 05:44:15 +000042 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
43 -- DATASOURCE_SCAN |PARTITIONED|
44 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
45 -- EMPTY_TUPLE_SOURCE |PARTITIONED|