blob: fc4ab7da4fbc67ded7891305d41821b82e2c3439 [file] [log] [blame]
buyingyib1dd8342014-11-26 14:37:12 -08001-- DISTRIBUTE_RESULT |PARTITIONED|
2 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
3 -- STREAM_PROJECT |PARTITIONED|
4 -- ASSIGN |PARTITIONED|
5 -- SORT_MERGE_EXCHANGE [$$1(ASC), $$2(ASC) ] |PARTITIONED|
6 -- PRE_CLUSTERED_GROUP_BY[$$34, $$35] |PARTITIONED|
7 {
8 -- AGGREGATE |LOCAL|
9 -- NESTED_TUPLE_SOURCE |LOCAL|
10 }
11 {
12 -- AGGREGATE |LOCAL|
13 -- NESTED_TUPLE_SOURCE |LOCAL|
14 }
15 -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$34(ASC), $$35(ASC)] HASH:[$$34, $$35] |PARTITIONED|
16 -- PRE_CLUSTERED_GROUP_BY[$$23, $$24] |PARTITIONED|
17 {
18 -- AGGREGATE |LOCAL|
19 -- STREAM_SELECT |LOCAL|
20 -- NESTED_TUPLE_SOURCE |LOCAL|
21 }
22 {
23 -- AGGREGATE |LOCAL|
24 -- STREAM_SELECT |LOCAL|
25 -- NESTED_TUPLE_SOURCE |LOCAL|
26 }
27 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
28 -- STABLE_SORT [$$23(ASC), $$24(ASC)] |PARTITIONED|
29 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
30 -- STREAM_SELECT |PARTITIONED|
31 -- ASSIGN |PARTITIONED|
32 -- STREAM_PROJECT |PARTITIONED|
33 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
34 -- DATASOURCE_SCAN |PARTITIONED|
35 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
36 -- EMPTY_TUPLE_SOURCE |PARTITIONED|