blob: 8f0100c25457cfa764c4aa685588284608bb331f [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[$$42] |PARTITIONED|
8 {
9 -- AGGREGATE |LOCAL|
10 -- MICRO_PRE_CLUSTERED_GROUP_BY[$$40] |LOCAL|
11 {
12 -- AGGREGATE |LOCAL|
13 -- MICRO_PRE_CLUSTERED_GROUP_BY[$$37, $$38] |LOCAL|
14 {
15 -- AGGREGATE |LOCAL|
16 -- STREAM_SELECT |LOCAL|
17 -- NESTED_TUPLE_SOURCE |LOCAL|
18 }
19 -- IN_MEMORY_STABLE_SORT [$$37(ASC), $$38(ASC)] |LOCAL|
20 -- STREAM_SELECT |LOCAL|
21 -- NESTED_TUPLE_SOURCE |LOCAL|
22 }
23 -- IN_MEMORY_STABLE_SORT [$$40(ASC), $$38(ASC)] |LOCAL|
24 -- STREAM_SELECT |LOCAL|
25 -- NESTED_TUPLE_SOURCE |LOCAL|
26 }
27 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
28 -- STABLE_SORT [$$42(ASC), $$40(ASC)] |PARTITIONED|
29 -- HASH_PARTITION_EXCHANGE [$$42] |PARTITIONED|
30 -- STREAM_PROJECT |PARTITIONED|
31 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
32 -- HYBRID_HASH_JOIN [$$48, $$50][$$34, $$35] |PARTITIONED|
33 -- HASH_PARTITION_EXCHANGE [$$48, $$50] |PARTITIONED|
34 -- HYBRID_HASH_JOIN [$$40][$$37] |PARTITIONED|
35 -- HASH_PARTITION_EXCHANGE [$$40] |PARTITIONED|
36 -- STREAM_PROJECT |PARTITIONED|
37 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
38 -- HYBRID_HASH_JOIN [$$42][$$43] |PARTITIONED|
39 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
40 -- DATASOURCE_SCAN |PARTITIONED|
41 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
42 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
43 -- HASH_PARTITION_EXCHANGE [$$43] |PARTITIONED|
44 -- ASSIGN |PARTITIONED|
45 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
46 -- DATASOURCE_SCAN |PARTITIONED|
47 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
48 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
49 -- HASH_PARTITION_EXCHANGE [$$37] |PARTITIONED|
50 -- ASSIGN |PARTITIONED|
51 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
52 -- DATASOURCE_SCAN |PARTITIONED|
53 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
54 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
55 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
56 -- ASSIGN |PARTITIONED|
57 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
58 -- DATASOURCE_SCAN |PARTITIONED|
59 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
60 -- EMPTY_TUPLE_SOURCE |PARTITIONED|