blob: 533a8b1f7892c2b041b1b31c5c5c7dbe5f96cbb7 [file] [log] [blame]
icetindile8fd4cc2014-08-05 20:25:16 -07001-- DISTRIBUTE_RESULT |PARTITIONED|
2 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
3 -- STREAM_PROJECT |PARTITIONED|
4 -- ASSIGN |PARTITIONED|
5 -- STREAM_PROJECT |PARTITIONED|
6 -- SORT_MERGE_EXCHANGE [$$93(ASC), $$94(ASC) ] |PARTITIONED|
7 -- STABLE_SORT [$$93(ASC), $$94(ASC)] |PARTITIONED|
8 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
9 -- STREAM_PROJECT |PARTITIONED|
10 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
11 -- HYBRID_HASH_JOIN [$$94, $$93][$$100, $$102] |PARTITIONED|
12 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
13 -- NESTED_LOOP |PARTITIONED|
14 -- BROADCAST_EXCHANGE |PARTITIONED|
15 -- DATASOURCE_SCAN |PARTITIONED|
16 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
17 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
18 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
19 -- STREAM_PROJECT |PARTITIONED|
20 -- ASSIGN |PARTITIONED|
21 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
22 -- SPLIT |PARTITIONED|
23 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
24 -- DATASOURCE_SCAN |PARTITIONED|
25 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
26 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
27 -- HASH_PARTITION_EXCHANGE [$$100] |PARTITIONED|
28 -- STREAM_PROJECT |PARTITIONED|
29 -- ASSIGN |PARTITIONED|
30 -- STREAM_PROJECT |PARTITIONED|
31 -- ASSIGN |PARTITIONED|
32 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
33 -- PRE_CLUSTERED_GROUP_BY[$$91, $$92] |PARTITIONED|
34 {
35 -- AGGREGATE |LOCAL|
36 -- NESTED_TUPLE_SOURCE |LOCAL|
37 }
38 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
39 -- STABLE_SORT [$$91(ASC), $$92(ASC)] |PARTITIONED|
40 -- HASH_PARTITION_EXCHANGE [$$91, $$92] |PARTITIONED|
41 -- STREAM_SELECT |PARTITIONED|
42 -- STREAM_PROJECT |PARTITIONED|
43 -- ASSIGN |PARTITIONED|
44 -- STREAM_SELECT |PARTITIONED|
45 -- STREAM_PROJECT |PARTITIONED|
46 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
47 -- HYBRID_HASH_JOIN [$$12][$$23] |PARTITIONED|
48 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
49 -- STREAM_PROJECT |PARTITIONED|
50 -- ASSIGN |PARTITIONED|
51 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
52 -- SPLIT |PARTITIONED|
53 -- HASH_PARTITION_EXCHANGE [$$23] |PARTITIONED|
54 -- STREAM_PROJECT |PARTITIONED|
55 -- UNNEST |PARTITIONED|
56 -- STREAM_PROJECT |PARTITIONED|
57 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
58 -- PRE_CLUSTERED_GROUP_BY[$$105] |PARTITIONED|
59 {
60 -- AGGREGATE |LOCAL|
61 -- STREAM_SELECT |LOCAL|
62 -- NESTED_TUPLE_SOURCE |LOCAL|
63 }
64 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
65 -- STABLE_SORT [$$105(ASC), $$21(ASC)] |PARTITIONED|
66 -- HASH_PARTITION_EXCHANGE [$$105] |PARTITIONED|
67 -- STREAM_PROJECT |PARTITIONED|
68 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
69 -- HYBRID_HASH_JOIN [$$15][$$18] |PARTITIONED|
70 -- HASH_PARTITION_EXCHANGE [$$15] |PARTITIONED|
71 -- UNNEST |PARTITIONED|
72 -- ASSIGN |PARTITIONED|
73 -- STREAM_PROJECT |PARTITIONED|
74 -- ASSIGN |PARTITIONED|
75 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
76 -- DATASOURCE_SCAN |PARTITIONED|
77 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
78 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
79 -- HASH_PARTITION_EXCHANGE [$$18] |PARTITIONED|
80 -- RUNNING_AGGREGATE |PARTITIONED|
81 -- STREAM_PROJECT |PARTITIONED|
82 -- SORT_MERGE_EXCHANGE [$$107(ASC), $$18(ASC) ] |PARTITIONED|
83 -- STABLE_SORT [$$107(ASC), $$18(ASC)] |PARTITIONED|
84 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
85 -- PRE_CLUSTERED_GROUP_BY[$$135] |PARTITIONED|
86 {
87 -- AGGREGATE |LOCAL|
88 -- NESTED_TUPLE_SOURCE |LOCAL|
89 }
90 -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$135(ASC)] HASH:[$$135] |PARTITIONED|
91 -- SORT_GROUP_BY[$$17] |PARTITIONED|
92 {
93 -- AGGREGATE |LOCAL|
94 -- NESTED_TUPLE_SOURCE |LOCAL|
95 }
96 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
97 -- STREAM_PROJECT |PARTITIONED|
98 -- UNNEST |PARTITIONED|
99 -- STREAM_PROJECT |PARTITIONED|
100 -- ASSIGN |PARTITIONED|
101 -- STREAM_PROJECT |PARTITIONED|
102 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
103 -- SPLIT |PARTITIONED|
104 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
105 -- DATASOURCE_SCAN |PARTITIONED|
106 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
107 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
108 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
109 -- SPLIT |PARTITIONED|
110 -- HASH_PARTITION_EXCHANGE [$$23] |PARTITIONED|
111 -- STREAM_PROJECT |PARTITIONED|
112 -- UNNEST |PARTITIONED|
113 -- STREAM_PROJECT |PARTITIONED|
114 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
115 -- PRE_CLUSTERED_GROUP_BY[$$105] |PARTITIONED|
116 {
117 -- AGGREGATE |LOCAL|
118 -- STREAM_SELECT |LOCAL|
119 -- NESTED_TUPLE_SOURCE |LOCAL|
120 }
121 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
122 -- STABLE_SORT [$$105(ASC), $$21(ASC)] |PARTITIONED|
123 -- HASH_PARTITION_EXCHANGE [$$105] |PARTITIONED|
124 -- STREAM_PROJECT |PARTITIONED|
125 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
126 -- HYBRID_HASH_JOIN [$$15][$$18] |PARTITIONED|
127 -- HASH_PARTITION_EXCHANGE [$$15] |PARTITIONED|
128 -- UNNEST |PARTITIONED|
129 -- ASSIGN |PARTITIONED|
130 -- STREAM_PROJECT |PARTITIONED|
131 -- ASSIGN |PARTITIONED|
132 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
133 -- DATASOURCE_SCAN |PARTITIONED|
134 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
135 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
136 -- HASH_PARTITION_EXCHANGE [$$18] |PARTITIONED|
137 -- RUNNING_AGGREGATE |PARTITIONED|
138 -- STREAM_PROJECT |PARTITIONED|
139 -- SORT_MERGE_EXCHANGE [$$107(ASC), $$18(ASC) ] |PARTITIONED|
140 -- STABLE_SORT [$$107(ASC), $$18(ASC)] |PARTITIONED|
141 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
142 -- PRE_CLUSTERED_GROUP_BY[$$135] |PARTITIONED|
143 {
144 -- AGGREGATE |LOCAL|
145 -- NESTED_TUPLE_SOURCE |LOCAL|
146 }
147 -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$135(ASC)] HASH:[$$135] |PARTITIONED|
148 -- SORT_GROUP_BY[$$17] |PARTITIONED|
149 {
150 -- AGGREGATE |LOCAL|
151 -- NESTED_TUPLE_SOURCE |LOCAL|
152 }
153 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
154 -- STREAM_PROJECT |PARTITIONED|
155 -- UNNEST |PARTITIONED|
156 -- STREAM_PROJECT |PARTITIONED|
157 -- ASSIGN |PARTITIONED|
158 -- STREAM_PROJECT |PARTITIONED|
159 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
160 -- SPLIT |PARTITIONED|
161 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
162 -- DATASOURCE_SCAN |PARTITIONED|
163 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
164 -- EMPTY_TUPLE_SOURCE |PARTITIONED|