blob: f22f71a533958d32f492cb2a9e53fb04ebd3e83e [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|
Yingyi Bu1e7760c2016-02-22 16:25:42 -080011 -- HYBRID_HASH_JOIN [$$26][$$94] |PARTITIONED|
buyingyia9a02022015-01-15 10:40:15 -080012 -- HASH_PARTITION_EXCHANGE [$$26] |PARTITIONED|
Yingyi Bu1e7760c2016-02-22 16:25:42 -080013 -- STREAM_PROJECT |PARTITIONED|
buyingyia9a02022015-01-15 10:40:15 -080014 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Yingyi Bu1e7760c2016-02-22 16:25:42 -080015 -- HYBRID_HASH_JOIN [$$93][$$25] |PARTITIONED|
16 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
17 -- DATASOURCE_SCAN |PARTITIONED|
18 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
19 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
20 -- HASH_PARTITION_EXCHANGE [$$25] |PARTITIONED|
21 -- PRE_CLUSTERED_GROUP_BY[$$122, $$124] |PARTITIONED|
22 {
23 -- AGGREGATE |LOCAL|
24 -- NESTED_TUPLE_SOURCE |LOCAL|
25 }
26 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
27 -- STABLE_SORT [$$122(ASC), $$124(ASC)] |PARTITIONED|
28 -- HASH_PARTITION_EXCHANGE [$$122, $$124] |PARTITIONED|
29 -- STREAM_PROJECT |PARTITIONED|
30 -- ASSIGN |PARTITIONED|
31 -- STREAM_SELECT |PARTITIONED|
Yingyi Bu947fc3c2016-01-27 20:14:47 -080032 -- STREAM_PROJECT |PARTITIONED|
Yingyi Bu1e7760c2016-02-22 16:25:42 -080033 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
34 -- HYBRID_HASH_JOIN [$$12][$$23] |PARTITIONED|
Yingyi Bu947fc3c2016-01-27 20:14:47 -080035 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Yingyi Bu1e7760c2016-02-22 16:25:42 -080036 -- STREAM_PROJECT |PARTITIONED|
37 -- ASSIGN |PARTITIONED|
38 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
39 -- SPLIT |PARTITIONED|
40 -- HASH_PARTITION_EXCHANGE [$$23] |PARTITIONED|
41 -- UNNEST |PARTITIONED|
42 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
43 -- PRE_CLUSTERED_GROUP_BY[$$97] |PARTITIONED|
44 {
45 -- AGGREGATE |LOCAL|
46 -- STREAM_SELECT |LOCAL|
47 -- NESTED_TUPLE_SOURCE |LOCAL|
48 }
49 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
50 -- STABLE_SORT [$$97(ASC), $$21(ASC)] |PARTITIONED|
51 -- HASH_PARTITION_EXCHANGE [$$97] |PARTITIONED|
Yingyi Bu947fc3c2016-01-27 20:14:47 -080052 -- STREAM_PROJECT |PARTITIONED|
Yingyi Bu1e7760c2016-02-22 16:25:42 -080053 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
54 -- HYBRID_HASH_JOIN [$$15][$$18] |PARTITIONED|
55 -- HASH_PARTITION_EXCHANGE [$$15] |PARTITIONED|
56 -- STREAM_PROJECT |PARTITIONED|
57 -- UNNEST |PARTITIONED|
58 -- ASSIGN |PARTITIONED|
Yingyi Bu947fc3c2016-01-27 20:14:47 -080059 -- STREAM_PROJECT |PARTITIONED|
Yingyi Bu1e7760c2016-02-22 16:25:42 -080060 -- ASSIGN |PARTITIONED|
61 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
62 -- DATASOURCE_SCAN |PARTITIONED|
63 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
64 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
65 -- HASH_PARTITION_EXCHANGE [$$18] |PARTITIONED|
66 -- ASSIGN |PARTITIONED|
67 -- RUNNING_AGGREGATE |PARTITIONED|
68 -- STREAM_PROJECT |PARTITIONED|
69 -- SORT_MERGE_EXCHANGE [$$102(ASC), $$18(ASC) ] |PARTITIONED|
70 -- STABLE_SORT [$$102(ASC), $$18(ASC)] |PARTITIONED|
71 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
72 -- PRE_CLUSTERED_GROUP_BY[$$130] |PARTITIONED|
73 {
74 -- AGGREGATE |LOCAL|
75 -- NESTED_TUPLE_SOURCE |LOCAL|
76 }
77 -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$130(ASC)] HASH:[$$130] |PARTITIONED|
78 -- SORT_GROUP_BY[$$17] |PARTITIONED|
79 {
80 -- AGGREGATE |LOCAL|
81 -- NESTED_TUPLE_SOURCE |LOCAL|
82 }
83 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
84 -- STREAM_PROJECT |PARTITIONED|
85 -- UNNEST |PARTITIONED|
86 -- STREAM_PROJECT |PARTITIONED|
87 -- ASSIGN |PARTITIONED|
88 -- STREAM_PROJECT |PARTITIONED|
89 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
90 -- SPLIT |PARTITIONED|
91 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
92 -- DATASOURCE_SCAN |PARTITIONED|
93 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
94 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
95 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
96 -- SPLIT |PARTITIONED|
97 -- HASH_PARTITION_EXCHANGE [$$23] |PARTITIONED|
98 -- UNNEST |PARTITIONED|
99 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
100 -- PRE_CLUSTERED_GROUP_BY[$$97] |PARTITIONED|
101 {
102 -- AGGREGATE |LOCAL|
103 -- STREAM_SELECT |LOCAL|
104 -- NESTED_TUPLE_SOURCE |LOCAL|
105 }
106 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
107 -- STABLE_SORT [$$97(ASC), $$21(ASC)] |PARTITIONED|
108 -- HASH_PARTITION_EXCHANGE [$$97] |PARTITIONED|
109 -- STREAM_PROJECT |PARTITIONED|
110 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
111 -- HYBRID_HASH_JOIN [$$15][$$18] |PARTITIONED|
112 -- HASH_PARTITION_EXCHANGE [$$15] |PARTITIONED|
113 -- STREAM_PROJECT |PARTITIONED|
114 -- UNNEST |PARTITIONED|
115 -- ASSIGN |PARTITIONED|
116 -- STREAM_PROJECT |PARTITIONED|
117 -- ASSIGN |PARTITIONED|
118 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
119 -- DATASOURCE_SCAN |PARTITIONED|
120 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
121 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
122 -- HASH_PARTITION_EXCHANGE [$$18] |PARTITIONED|
123 -- ASSIGN |PARTITIONED|
124 -- RUNNING_AGGREGATE |PARTITIONED|
125 -- STREAM_PROJECT |PARTITIONED|
126 -- SORT_MERGE_EXCHANGE [$$102(ASC), $$18(ASC) ] |PARTITIONED|
127 -- STABLE_SORT [$$102(ASC), $$18(ASC)] |PARTITIONED|
128 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
129 -- PRE_CLUSTERED_GROUP_BY[$$130] |PARTITIONED|
130 {
131 -- AGGREGATE |LOCAL|
132 -- NESTED_TUPLE_SOURCE |LOCAL|
133 }
134 -- HASH_PARTITION_MERGE_EXCHANGE MERGE:[$$130(ASC)] HASH:[$$130] |PARTITIONED|
135 -- SORT_GROUP_BY[$$17] |PARTITIONED|
136 {
137 -- AGGREGATE |LOCAL|
138 -- NESTED_TUPLE_SOURCE |LOCAL|
139 }
140 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
buyingyia9a02022015-01-15 10:40:15 -0800141 -- STREAM_PROJECT |PARTITIONED|
Yingyi Bu1e7760c2016-02-22 16:25:42 -0800142 -- UNNEST |PARTITIONED|
143 -- STREAM_PROJECT |PARTITIONED|
144 -- ASSIGN |PARTITIONED|
145 -- STREAM_PROJECT |PARTITIONED|
buyingyia9a02022015-01-15 10:40:15 -0800146 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
Yingyi Bu1e7760c2016-02-22 16:25:42 -0800147 -- SPLIT |PARTITIONED|
148 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
149 -- DATASOURCE_SCAN |PARTITIONED|
150 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
151 -- EMPTY_TUPLE_SOURCE |PARTITIONED|
152 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
153 -- STREAM_PROJECT |PARTITIONED|
154 -- ASSIGN |PARTITIONED|
155 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
156 -- SPLIT |PARTITIONED|
157 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
158 -- DATASOURCE_SCAN |PARTITIONED|
159 -- ONE_TO_ONE_EXCHANGE |PARTITIONED|
160 -- EMPTY_TUPLE_SOURCE |PARTITIONED|