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