@@ -78,7 +78,7 @@ Condition : (isnotnull(i_item_sk#5) AND isnotnull(i_item_id#6))
78
78
79
79
(7) BroadcastExchange
80
80
Input [2]: [i_item_sk#5, i_item_id#6]
81
- Arguments: HashedRelationBroadcastMode(List(cast(input[0, int, false] as bigint)),false), [id=#7 ]
81
+ Arguments: HashedRelationBroadcastMode(List(cast(input[0, int, false] as bigint)),false), [plan_id=1 ]
82
82
83
83
(8) BroadcastHashJoin [codegen id : 5]
84
84
Left keys [1]: [sr_item_sk#1]
@@ -90,178 +90,178 @@ Output [3]: [sr_return_quantity#2, sr_returned_date_sk#3, i_item_id#6]
90
90
Input [5]: [sr_item_sk#1, sr_return_quantity#2, sr_returned_date_sk#3, i_item_sk#5, i_item_id#6]
91
91
92
92
(10) ReusedExchange [Reuses operator id: 62]
93
- Output [1]: [d_date_sk#8 ]
93
+ Output [1]: [d_date_sk#7 ]
94
94
95
95
(11) BroadcastHashJoin [codegen id : 5]
96
96
Left keys [1]: [sr_returned_date_sk#3]
97
- Right keys [1]: [d_date_sk#8 ]
97
+ Right keys [1]: [d_date_sk#7 ]
98
98
Join condition: None
99
99
100
100
(12) Project [codegen id : 5]
101
101
Output [2]: [sr_return_quantity#2, i_item_id#6]
102
- Input [4]: [sr_return_quantity#2, sr_returned_date_sk#3, i_item_id#6, d_date_sk#8 ]
102
+ Input [4]: [sr_return_quantity#2, sr_returned_date_sk#3, i_item_id#6, d_date_sk#7 ]
103
103
104
104
(13) HashAggregate [codegen id : 5]
105
105
Input [2]: [sr_return_quantity#2, i_item_id#6]
106
106
Keys [1]: [i_item_id#6]
107
107
Functions [1]: [partial_sum(sr_return_quantity#2)]
108
- Aggregate Attributes [1]: [sum#9 ]
109
- Results [2]: [i_item_id#6, sum#10 ]
108
+ Aggregate Attributes [1]: [sum#8 ]
109
+ Results [2]: [i_item_id#6, sum#9 ]
110
110
111
111
(14) Exchange
112
- Input [2]: [i_item_id#6, sum#10 ]
113
- Arguments: hashpartitioning(i_item_id#6, 5), ENSURE_REQUIREMENTS, [id=#11 ]
112
+ Input [2]: [i_item_id#6, sum#9 ]
113
+ Arguments: hashpartitioning(i_item_id#6, 5), ENSURE_REQUIREMENTS, [plan_id=2 ]
114
114
115
115
(15) HashAggregate [codegen id : 18]
116
- Input [2]: [i_item_id#6, sum#10 ]
116
+ Input [2]: [i_item_id#6, sum#9 ]
117
117
Keys [1]: [i_item_id#6]
118
118
Functions [1]: [sum(sr_return_quantity#2)]
119
- Aggregate Attributes [1]: [sum(sr_return_quantity#2)#12 ]
120
- Results [2]: [i_item_id#6 AS item_id#13 , sum(sr_return_quantity#2)#12 AS sr_item_qty#14 ]
119
+ Aggregate Attributes [1]: [sum(sr_return_quantity#2)#10 ]
120
+ Results [2]: [i_item_id#6 AS item_id#11 , sum(sr_return_quantity#2)#10 AS sr_item_qty#12 ]
121
121
122
122
(16) Scan parquet default.catalog_returns
123
- Output [3]: [cr_item_sk#15 , cr_return_quantity#16 , cr_returned_date_sk#17 ]
123
+ Output [3]: [cr_item_sk#13 , cr_return_quantity#14 , cr_returned_date_sk#15 ]
124
124
Batched: true
125
125
Location: InMemoryFileIndex []
126
- PartitionFilters: [isnotnull(cr_returned_date_sk#17 ), dynamicpruningexpression(cr_returned_date_sk#17 IN dynamicpruning#4)]
126
+ PartitionFilters: [isnotnull(cr_returned_date_sk#15 ), dynamicpruningexpression(cr_returned_date_sk#15 IN dynamicpruning#4)]
127
127
PushedFilters: [IsNotNull(cr_item_sk)]
128
128
ReadSchema: struct<cr_item_sk:int,cr_return_quantity:int>
129
129
130
130
(17) ColumnarToRow [codegen id : 10]
131
- Input [3]: [cr_item_sk#15 , cr_return_quantity#16 , cr_returned_date_sk#17 ]
131
+ Input [3]: [cr_item_sk#13 , cr_return_quantity#14 , cr_returned_date_sk#15 ]
132
132
133
133
(18) Filter [codegen id : 10]
134
- Input [3]: [cr_item_sk#15 , cr_return_quantity#16 , cr_returned_date_sk#17 ]
135
- Condition : isnotnull(cr_item_sk#15 )
134
+ Input [3]: [cr_item_sk#13 , cr_return_quantity#14 , cr_returned_date_sk#15 ]
135
+ Condition : isnotnull(cr_item_sk#13 )
136
136
137
137
(19) ReusedExchange [Reuses operator id: 7]
138
- Output [2]: [i_item_sk#18 , i_item_id#19 ]
138
+ Output [2]: [i_item_sk#16 , i_item_id#17 ]
139
139
140
140
(20) BroadcastHashJoin [codegen id : 10]
141
- Left keys [1]: [cr_item_sk#15 ]
142
- Right keys [1]: [i_item_sk#18 ]
141
+ Left keys [1]: [cr_item_sk#13 ]
142
+ Right keys [1]: [i_item_sk#16 ]
143
143
Join condition: None
144
144
145
145
(21) Project [codegen id : 10]
146
- Output [3]: [cr_return_quantity#16 , cr_returned_date_sk#17 , i_item_id#19 ]
147
- Input [5]: [cr_item_sk#15 , cr_return_quantity#16 , cr_returned_date_sk#17 , i_item_sk#18 , i_item_id#19 ]
146
+ Output [3]: [cr_return_quantity#14 , cr_returned_date_sk#15 , i_item_id#17 ]
147
+ Input [5]: [cr_item_sk#13 , cr_return_quantity#14 , cr_returned_date_sk#15 , i_item_sk#16 , i_item_id#17 ]
148
148
149
149
(22) ReusedExchange [Reuses operator id: 62]
150
- Output [1]: [d_date_sk#20 ]
150
+ Output [1]: [d_date_sk#18 ]
151
151
152
152
(23) BroadcastHashJoin [codegen id : 10]
153
- Left keys [1]: [cr_returned_date_sk#17 ]
154
- Right keys [1]: [d_date_sk#20 ]
153
+ Left keys [1]: [cr_returned_date_sk#15 ]
154
+ Right keys [1]: [d_date_sk#18 ]
155
155
Join condition: None
156
156
157
157
(24) Project [codegen id : 10]
158
- Output [2]: [cr_return_quantity#16 , i_item_id#19 ]
159
- Input [4]: [cr_return_quantity#16 , cr_returned_date_sk#17 , i_item_id#19 , d_date_sk#20 ]
158
+ Output [2]: [cr_return_quantity#14 , i_item_id#17 ]
159
+ Input [4]: [cr_return_quantity#14 , cr_returned_date_sk#15 , i_item_id#17 , d_date_sk#18 ]
160
160
161
161
(25) HashAggregate [codegen id : 10]
162
- Input [2]: [cr_return_quantity#16 , i_item_id#19 ]
163
- Keys [1]: [i_item_id#19 ]
164
- Functions [1]: [partial_sum(cr_return_quantity#16 )]
165
- Aggregate Attributes [1]: [sum#21 ]
166
- Results [2]: [i_item_id#19 , sum#22 ]
162
+ Input [2]: [cr_return_quantity#14 , i_item_id#17 ]
163
+ Keys [1]: [i_item_id#17 ]
164
+ Functions [1]: [partial_sum(cr_return_quantity#14 )]
165
+ Aggregate Attributes [1]: [sum#19 ]
166
+ Results [2]: [i_item_id#17 , sum#20 ]
167
167
168
168
(26) Exchange
169
- Input [2]: [i_item_id#19 , sum#22 ]
170
- Arguments: hashpartitioning(i_item_id#19 , 5), ENSURE_REQUIREMENTS, [id=#23 ]
169
+ Input [2]: [i_item_id#17 , sum#20 ]
170
+ Arguments: hashpartitioning(i_item_id#17 , 5), ENSURE_REQUIREMENTS, [plan_id=3 ]
171
171
172
172
(27) HashAggregate [codegen id : 11]
173
- Input [2]: [i_item_id#19 , sum#22 ]
174
- Keys [1]: [i_item_id#19 ]
175
- Functions [1]: [sum(cr_return_quantity#16 )]
176
- Aggregate Attributes [1]: [sum(cr_return_quantity#16)#24 ]
177
- Results [2]: [i_item_id#19 AS item_id#25 , sum(cr_return_quantity#16)#24 AS cr_item_qty#26 ]
173
+ Input [2]: [i_item_id#17 , sum#20 ]
174
+ Keys [1]: [i_item_id#17 ]
175
+ Functions [1]: [sum(cr_return_quantity#14 )]
176
+ Aggregate Attributes [1]: [sum(cr_return_quantity#14)#21 ]
177
+ Results [2]: [i_item_id#17 AS item_id#22 , sum(cr_return_quantity#14)#21 AS cr_item_qty#23 ]
178
178
179
179
(28) BroadcastExchange
180
- Input [2]: [item_id#25 , cr_item_qty#26 ]
181
- Arguments: HashedRelationBroadcastMode(List(input[0, string, true]),false), [id=#27 ]
180
+ Input [2]: [item_id#22 , cr_item_qty#23 ]
181
+ Arguments: HashedRelationBroadcastMode(List(input[0, string, true]),false), [plan_id=4 ]
182
182
183
183
(29) BroadcastHashJoin [codegen id : 18]
184
- Left keys [1]: [item_id#13 ]
185
- Right keys [1]: [item_id#25 ]
184
+ Left keys [1]: [item_id#11 ]
185
+ Right keys [1]: [item_id#22 ]
186
186
Join condition: None
187
187
188
188
(30) Project [codegen id : 18]
189
- Output [3]: [item_id#13 , sr_item_qty#14 , cr_item_qty#26 ]
190
- Input [4]: [item_id#13 , sr_item_qty#14 , item_id#25 , cr_item_qty#26 ]
189
+ Output [3]: [item_id#11 , sr_item_qty#12 , cr_item_qty#23 ]
190
+ Input [4]: [item_id#11 , sr_item_qty#12 , item_id#22 , cr_item_qty#23 ]
191
191
192
192
(31) Scan parquet default.web_returns
193
- Output [3]: [wr_item_sk#28 , wr_return_quantity#29 , wr_returned_date_sk#30 ]
193
+ Output [3]: [wr_item_sk#24 , wr_return_quantity#25 , wr_returned_date_sk#26 ]
194
194
Batched: true
195
195
Location: InMemoryFileIndex []
196
- PartitionFilters: [isnotnull(wr_returned_date_sk#30 ), dynamicpruningexpression(wr_returned_date_sk#30 IN dynamicpruning#4)]
196
+ PartitionFilters: [isnotnull(wr_returned_date_sk#26 ), dynamicpruningexpression(wr_returned_date_sk#26 IN dynamicpruning#4)]
197
197
PushedFilters: [IsNotNull(wr_item_sk)]
198
198
ReadSchema: struct<wr_item_sk:int,wr_return_quantity:int>
199
199
200
200
(32) ColumnarToRow [codegen id : 16]
201
- Input [3]: [wr_item_sk#28 , wr_return_quantity#29 , wr_returned_date_sk#30 ]
201
+ Input [3]: [wr_item_sk#24 , wr_return_quantity#25 , wr_returned_date_sk#26 ]
202
202
203
203
(33) Filter [codegen id : 16]
204
- Input [3]: [wr_item_sk#28 , wr_return_quantity#29 , wr_returned_date_sk#30 ]
205
- Condition : isnotnull(wr_item_sk#28 )
204
+ Input [3]: [wr_item_sk#24 , wr_return_quantity#25 , wr_returned_date_sk#26 ]
205
+ Condition : isnotnull(wr_item_sk#24 )
206
206
207
207
(34) ReusedExchange [Reuses operator id: 7]
208
- Output [2]: [i_item_sk#31 , i_item_id#32 ]
208
+ Output [2]: [i_item_sk#27 , i_item_id#28 ]
209
209
210
210
(35) BroadcastHashJoin [codegen id : 16]
211
- Left keys [1]: [wr_item_sk#28 ]
212
- Right keys [1]: [i_item_sk#31 ]
211
+ Left keys [1]: [wr_item_sk#24 ]
212
+ Right keys [1]: [i_item_sk#27 ]
213
213
Join condition: None
214
214
215
215
(36) Project [codegen id : 16]
216
- Output [3]: [wr_return_quantity#29 , wr_returned_date_sk#30 , i_item_id#32 ]
217
- Input [5]: [wr_item_sk#28 , wr_return_quantity#29 , wr_returned_date_sk#30 , i_item_sk#31 , i_item_id#32 ]
216
+ Output [3]: [wr_return_quantity#25 , wr_returned_date_sk#26 , i_item_id#28 ]
217
+ Input [5]: [wr_item_sk#24 , wr_return_quantity#25 , wr_returned_date_sk#26 , i_item_sk#27 , i_item_id#28 ]
218
218
219
219
(37) ReusedExchange [Reuses operator id: 62]
220
- Output [1]: [d_date_sk#33 ]
220
+ Output [1]: [d_date_sk#29 ]
221
221
222
222
(38) BroadcastHashJoin [codegen id : 16]
223
- Left keys [1]: [wr_returned_date_sk#30 ]
224
- Right keys [1]: [d_date_sk#33 ]
223
+ Left keys [1]: [wr_returned_date_sk#26 ]
224
+ Right keys [1]: [d_date_sk#29 ]
225
225
Join condition: None
226
226
227
227
(39) Project [codegen id : 16]
228
- Output [2]: [wr_return_quantity#29 , i_item_id#32 ]
229
- Input [4]: [wr_return_quantity#29 , wr_returned_date_sk#30 , i_item_id#32 , d_date_sk#33 ]
228
+ Output [2]: [wr_return_quantity#25 , i_item_id#28 ]
229
+ Input [4]: [wr_return_quantity#25 , wr_returned_date_sk#26 , i_item_id#28 , d_date_sk#29 ]
230
230
231
231
(40) HashAggregate [codegen id : 16]
232
- Input [2]: [wr_return_quantity#29 , i_item_id#32 ]
233
- Keys [1]: [i_item_id#32 ]
234
- Functions [1]: [partial_sum(wr_return_quantity#29 )]
235
- Aggregate Attributes [1]: [sum#34 ]
236
- Results [2]: [i_item_id#32 , sum#35 ]
232
+ Input [2]: [wr_return_quantity#25 , i_item_id#28 ]
233
+ Keys [1]: [i_item_id#28 ]
234
+ Functions [1]: [partial_sum(wr_return_quantity#25 )]
235
+ Aggregate Attributes [1]: [sum#30 ]
236
+ Results [2]: [i_item_id#28 , sum#31 ]
237
237
238
238
(41) Exchange
239
- Input [2]: [i_item_id#32 , sum#35 ]
240
- Arguments: hashpartitioning(i_item_id#32 , 5), ENSURE_REQUIREMENTS, [id=#36 ]
239
+ Input [2]: [i_item_id#28 , sum#31 ]
240
+ Arguments: hashpartitioning(i_item_id#28 , 5), ENSURE_REQUIREMENTS, [plan_id=5 ]
241
241
242
242
(42) HashAggregate [codegen id : 17]
243
- Input [2]: [i_item_id#32 , sum#35 ]
244
- Keys [1]: [i_item_id#32 ]
245
- Functions [1]: [sum(wr_return_quantity#29 )]
246
- Aggregate Attributes [1]: [sum(wr_return_quantity#29)#37 ]
247
- Results [2]: [i_item_id#32 AS item_id#38 , sum(wr_return_quantity#29)#37 AS wr_item_qty#39 ]
243
+ Input [2]: [i_item_id#28 , sum#31 ]
244
+ Keys [1]: [i_item_id#28 ]
245
+ Functions [1]: [sum(wr_return_quantity#25 )]
246
+ Aggregate Attributes [1]: [sum(wr_return_quantity#25)#32 ]
247
+ Results [2]: [i_item_id#28 AS item_id#33 , sum(wr_return_quantity#25)#32 AS wr_item_qty#34 ]
248
248
249
249
(43) BroadcastExchange
250
- Input [2]: [item_id#38 , wr_item_qty#39 ]
251
- Arguments: HashedRelationBroadcastMode(List(input[0, string, true]),false), [id=#40 ]
250
+ Input [2]: [item_id#33 , wr_item_qty#34 ]
251
+ Arguments: HashedRelationBroadcastMode(List(input[0, string, true]),false), [plan_id=6 ]
252
252
253
253
(44) BroadcastHashJoin [codegen id : 18]
254
- Left keys [1]: [item_id#13 ]
255
- Right keys [1]: [item_id#38 ]
254
+ Left keys [1]: [item_id#11 ]
255
+ Right keys [1]: [item_id#33 ]
256
256
Join condition: None
257
257
258
258
(45) Project [codegen id : 18]
259
- Output [8]: [item_id#13 , sr_item_qty#14 , (((cast(sr_item_qty#14 as double) / cast(((sr_item_qty#14 + cr_item_qty#26 ) + wr_item_qty#39 ) as double)) / 3.0) * 100.0) AS sr_dev#41 , cr_item_qty#26 , (((cast(cr_item_qty#26 as double) / cast(((sr_item_qty#14 + cr_item_qty#26 ) + wr_item_qty#39 ) as double)) / 3.0) * 100.0) AS cr_dev#42 , wr_item_qty#39 , (((cast(wr_item_qty#39 as double) / cast(((sr_item_qty#14 + cr_item_qty#26 ) + wr_item_qty#39 ) as double)) / 3.0) * 100.0) AS wr_dev#43 , CheckOverflow((promote_precision(cast(((sr_item_qty#14 + cr_item_qty#26 ) + wr_item_qty#39 ) as decimal(21,1))) / 3.0), DecimalType(27,6)) AS average#44 ]
260
- Input [5]: [item_id#13 , sr_item_qty#14 , cr_item_qty#26 , item_id#38 , wr_item_qty#39 ]
259
+ Output [8]: [item_id#11 , sr_item_qty#12 , (((cast(sr_item_qty#12 as double) / cast(((sr_item_qty#12 + cr_item_qty#23 ) + wr_item_qty#34 ) as double)) / 3.0) * 100.0) AS sr_dev#35 , cr_item_qty#23 , (((cast(cr_item_qty#23 as double) / cast(((sr_item_qty#12 + cr_item_qty#23 ) + wr_item_qty#34 ) as double)) / 3.0) * 100.0) AS cr_dev#36 , wr_item_qty#34 , (((cast(wr_item_qty#34 as double) / cast(((sr_item_qty#12 + cr_item_qty#23 ) + wr_item_qty#34 ) as double)) / 3.0) * 100.0) AS wr_dev#37 , CheckOverflow((promote_precision(cast(((sr_item_qty#12 + cr_item_qty#23 ) + wr_item_qty#34 ) as decimal(21,1))) / 3.0), DecimalType(27,6)) AS average#38 ]
260
+ Input [5]: [item_id#11 , sr_item_qty#12 , cr_item_qty#23 , item_id#33 , wr_item_qty#34 ]
261
261
262
262
(46) TakeOrderedAndProject
263
- Input [8]: [item_id#13 , sr_item_qty#14 , sr_dev#41 , cr_item_qty#26 , cr_dev#42 , wr_item_qty#39 , wr_dev#43 , average#44 ]
264
- Arguments: 100, [item_id#13 ASC NULLS FIRST, sr_item_qty#14 ASC NULLS FIRST], [item_id#13 , sr_item_qty#14 , sr_dev#41 , cr_item_qty#26 , cr_dev#42 , wr_item_qty#39 , wr_dev#43 , average#44 ]
263
+ Input [8]: [item_id#11 , sr_item_qty#12 , sr_dev#35 , cr_item_qty#23 , cr_dev#36 , wr_item_qty#34 , wr_dev#37 , average#38 ]
264
+ Arguments: 100, [item_id#11 ASC NULLS FIRST, sr_item_qty#12 ASC NULLS FIRST], [item_id#11 , sr_item_qty#12 , sr_dev#35 , cr_item_qty#23 , cr_dev#36 , wr_item_qty#34 , wr_dev#37 , average#38 ]
265
265
266
266
===== Subqueries =====
267
267
@@ -285,78 +285,78 @@ BroadcastExchange (62)
285
285
286
286
287
287
(47) Scan parquet default.date_dim
288
- Output [2]: [d_date_sk#8 , d_date#45 ]
288
+ Output [2]: [d_date_sk#7 , d_date#39 ]
289
289
Batched: true
290
290
Location [not included in comparison]/{warehouse_dir}/date_dim]
291
291
PushedFilters: [IsNotNull(d_date_sk)]
292
292
ReadSchema: struct<d_date_sk:int,d_date:date>
293
293
294
294
(48) ColumnarToRow [codegen id : 3]
295
- Input [2]: [d_date_sk#8 , d_date#45 ]
295
+ Input [2]: [d_date_sk#7 , d_date#39 ]
296
296
297
297
(49) Filter [codegen id : 3]
298
- Input [2]: [d_date_sk#8 , d_date#45 ]
299
- Condition : isnotnull(d_date_sk#8 )
298
+ Input [2]: [d_date_sk#7 , d_date#39 ]
299
+ Condition : isnotnull(d_date_sk#7 )
300
300
301
301
(50) Scan parquet default.date_dim
302
- Output [2]: [d_date#46 , d_week_seq#47 ]
302
+ Output [2]: [d_date#40 , d_week_seq#41 ]
303
303
Batched: true
304
304
Location [not included in comparison]/{warehouse_dir}/date_dim]
305
305
ReadSchema: struct<d_date:date,d_week_seq:int>
306
306
307
307
(51) ColumnarToRow [codegen id : 2]
308
- Input [2]: [d_date#46 , d_week_seq#47 ]
308
+ Input [2]: [d_date#40 , d_week_seq#41 ]
309
309
310
310
(52) Scan parquet default.date_dim
311
- Output [2]: [d_date#48 , d_week_seq#49 ]
311
+ Output [2]: [d_date#42 , d_week_seq#43 ]
312
312
Batched: true
313
313
Location [not included in comparison]/{warehouse_dir}/date_dim]
314
314
PushedFilters: [In(d_date, [2000-06-30,2000-09-27,2000-11-17])]
315
315
ReadSchema: struct<d_date:date,d_week_seq:int>
316
316
317
317
(53) ColumnarToRow [codegen id : 1]
318
- Input [2]: [d_date#48 , d_week_seq#49 ]
318
+ Input [2]: [d_date#42 , d_week_seq#43 ]
319
319
320
320
(54) Filter [codegen id : 1]
321
- Input [2]: [d_date#48 , d_week_seq#49 ]
322
- Condition : d_date#48 IN (2000-06-30,2000-09-27,2000-11-17)
321
+ Input [2]: [d_date#42 , d_week_seq#43 ]
322
+ Condition : d_date#42 IN (2000-06-30,2000-09-27,2000-11-17)
323
323
324
324
(55) Project [codegen id : 1]
325
- Output [1]: [d_week_seq#49 ]
326
- Input [2]: [d_date#48 , d_week_seq#49 ]
325
+ Output [1]: [d_week_seq#43 ]
326
+ Input [2]: [d_date#42 , d_week_seq#43 ]
327
327
328
328
(56) BroadcastExchange
329
- Input [1]: [d_week_seq#49 ]
330
- Arguments: HashedRelationBroadcastMode(List(cast(input[0, int, true] as bigint)),false), [id=#50 ]
329
+ Input [1]: [d_week_seq#43 ]
330
+ Arguments: HashedRelationBroadcastMode(List(cast(input[0, int, true] as bigint)),false), [plan_id=7 ]
331
331
332
332
(57) BroadcastHashJoin [codegen id : 2]
333
- Left keys [1]: [d_week_seq#47 ]
334
- Right keys [1]: [d_week_seq#49 ]
333
+ Left keys [1]: [d_week_seq#41 ]
334
+ Right keys [1]: [d_week_seq#43 ]
335
335
Join condition: None
336
336
337
337
(58) Project [codegen id : 2]
338
- Output [1]: [d_date#46 ]
339
- Input [2]: [d_date#46 , d_week_seq#47 ]
338
+ Output [1]: [d_date#40 ]
339
+ Input [2]: [d_date#40 , d_week_seq#41 ]
340
340
341
341
(59) BroadcastExchange
342
- Input [1]: [d_date#46 ]
343
- Arguments: HashedRelationBroadcastMode(List(input[0, date, true]),false), [id=#51 ]
342
+ Input [1]: [d_date#40 ]
343
+ Arguments: HashedRelationBroadcastMode(List(input[0, date, true]),false), [plan_id=8 ]
344
344
345
345
(60) BroadcastHashJoin [codegen id : 3]
346
- Left keys [1]: [d_date#45 ]
347
- Right keys [1]: [d_date#46 ]
346
+ Left keys [1]: [d_date#39 ]
347
+ Right keys [1]: [d_date#40 ]
348
348
Join condition: None
349
349
350
350
(61) Project [codegen id : 3]
351
- Output [1]: [d_date_sk#8 ]
352
- Input [2]: [d_date_sk#8 , d_date#45 ]
351
+ Output [1]: [d_date_sk#7 ]
352
+ Input [2]: [d_date_sk#7 , d_date#39 ]
353
353
354
354
(62) BroadcastExchange
355
- Input [1]: [d_date_sk#8 ]
356
- Arguments: HashedRelationBroadcastMode(List(cast(input[0, int, true] as bigint)),false), [id=#52 ]
355
+ Input [1]: [d_date_sk#7 ]
356
+ Arguments: HashedRelationBroadcastMode(List(cast(input[0, int, true] as bigint)),false), [plan_id=9 ]
357
357
358
- Subquery:2 Hosting operator id = 16 Hosting Expression = cr_returned_date_sk#17 IN dynamicpruning#4
358
+ Subquery:2 Hosting operator id = 16 Hosting Expression = cr_returned_date_sk#15 IN dynamicpruning#4
359
359
360
- Subquery:3 Hosting operator id = 31 Hosting Expression = wr_returned_date_sk#30 IN dynamicpruning#4
360
+ Subquery:3 Hosting operator id = 31 Hosting Expression = wr_returned_date_sk#26 IN dynamicpruning#4
361
361
362
362
0 commit comments