blob: 7b95d4d680fccaa0a0c38a56296ebb183304db88 [file] [log] [blame]
buyingyibd904112014-10-27 18:41:43 -07001-- DISTRIBUTE_RESULT |PARTITIONED|
2 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
3 -- STREAM_PROJECT |PARTITIONED|
4 -- ASSIGN |PARTITIONED|
5 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
6 -- PRE_CLUSTERED_GROUP_BY[$$52] |PARTITIONED|
7 {
8 -- AGGREGATE |LOCAL|
9 -- STREAM_LIMIT |LOCAL|
10 -- IN_MEMORY_STABLE_SORT [$$65(DESC)] |LOCAL|
11 -- NESTED_TUPLE_SOURCE |LOCAL|
12 }
13 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
14 -- STABLE_SORT [$$52(ASC)] |PARTITIONED|
15 -- HASH_PARTITION_EXCHANGE [$$52] |PARTITIONED|
16 -- STREAM_PROJECT |PARTITIONED|
17 -- ASSIGN |PARTITIONED|
18 -- STREAM_PROJECT |PARTITIONED|
19 -- ASSIGN |PARTITIONED|
20 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
21 -- PRE_CLUSTERED_GROUP_BY[$$69, $$70] |PARTITIONED|
22 {
23 -- AGGREGATE |LOCAL|
24 -- NESTED_TUPLE_SOURCE |LOCAL|
25 }
26 -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$69(ASC), $$70(ASC)] HASH:[$$69, $$70] |PARTITIONED|
27 -- SORT_GROUP_BY[$$50, $$54] |PARTITIONED|
28 {
29 -- AGGREGATE |LOCAL|
30 -- NESTED_TUPLE_SOURCE |LOCAL|
31 }
32 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
33 -- STREAM_PROJECT |PARTITIONED|
34 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
35 -- HYBRID_HASH_JOIN [$$56][$$60] |PARTITIONED|
36 -- HASH_PARTITION_EXCHANGE [$$56] |PARTITIONED|
37 -- STREAM_PROJECT |PARTITIONED|
38 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
39 -- HYBRID_HASH_JOIN [$$54][$$63] |PARTITIONED|
40 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
41 -- STREAM_PROJECT |PARTITIONED|
42 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
43 -- HYBRID_HASH_JOIN [$$54][$$55] |PARTITIONED|
44 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
45 -- STREAM_PROJECT |PARTITIONED|
46 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
47 -- DATASOURCE_SCAN |PARTITIONED|
48 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
49 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
50 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
51 -- STREAM_PROJECT |PARTITIONED|
52 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
53 -- DATASOURCE_SCAN |PARTITIONED|
54 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
55 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
56 -- HASH_PARTITION_EXCHANGE [$$63] |PARTITIONED|
57 -- STREAM_PROJECT |PARTITIONED|
58 -- ASSIGN |PARTITIONED|
59 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
60 -- DATASOURCE_SCAN |PARTITIONED|
61 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
62 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
63 -- HASH_PARTITION_EXCHANGE [$$60] |PARTITIONED|
64 -- STREAM_PROJECT |PARTITIONED|
65 -- ASSIGN |PARTITIONED|
66 -- STREAM_PROJECT |PARTITIONED|
67 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
68 -- DATASOURCE_SCAN |PARTITIONED|
69 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
70 -- EMPTY_TUPLE_SOURCE |PARTITIONED|