- Notifications
You must be signed in to change notification settings - Fork5
Commita191a16
committed
Change the planner-to-executor API so that the planner tells the executor
which comparison operators to use for plan nodes involving tuple comparison(Agg, Group, Unique, SetOp). Formerly the executor looked up the defaultequality operator for the datatype, which was really pretty shaky, since it'spossible that the data being fed to the node is sorted according to somenondefault operator class that could have an incompatible idea of equality.The planner knows what it has sorted by and therefore can provide the rightequality operator to use. Also, this change moves a couple of catalog lookupsout of the executor and into the planner, which should help startup time forpre-planned queries by some small amount. Modify the planner to remove someother cavalier assumptions about always being able to use the defaultoperators. Also add "nulls first/last" info to the Plan node for a mergejoin--- neither the executor nor the planner can cope yet, but at least the API isin place.1 parent5f6d735 commita191a16
File tree
25 files changed
+722
-263
lines changed- src
- backend
- executor
- nodes
- optimizer
- path
- plan
- util
- parser
- utils
- cache
- sort
- include
- executor
- nodes
- optimizer
- utils
25 files changed
+722
-263
lines changedLines changed: 20 additions & 29 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
8 | 8 |
| |
9 | 9 |
| |
10 | 10 |
| |
11 |
| - | |
| 11 | + | |
12 | 12 |
| |
13 | 13 |
| |
14 | 14 |
| |
| |||
183 | 183 |
| |
184 | 184 |
| |
185 | 185 |
| |
186 |
| - | |
187 |
| - | |
188 |
| - | |
| 186 | + | |
| 187 | + | |
189 | 188 |
| |
190 |
| - | |
| 189 | + | |
191 | 190 |
| |
192 | 191 |
| |
193 | 192 |
| |
194 | 193 |
| |
195 |
| - | |
196 |
| - | |
| 194 | + | |
197 | 195 |
| |
198 | 196 |
| |
199 |
| - | |
200 |
| - | |
| 197 | + | |
| 198 | + | |
201 | 199 |
| |
202 | 200 |
| |
203 |
| - | |
| 201 | + | |
204 | 202 |
| |
205 | 203 |
| |
206 | 204 |
| |
207 | 205 |
| |
208 | 206 |
| |
209 | 207 |
| |
210 | 208 |
| |
211 |
| - | |
212 |
| - | |
| 209 | + | |
| 210 | + | |
213 | 211 |
| |
214 | 212 |
| |
215 |
| - | |
216 |
| - | |
217 |
| - | |
218 |
| - | |
219 |
| - | |
| 213 | + | |
| 214 | + | |
| 215 | + | |
| 216 | + | |
220 | 217 |
| |
221 | 218 |
| |
222 | 219 |
| |
223 |
| - | |
224 |
| - | |
| 220 | + | |
| 221 | + | |
225 | 222 |
| |
226 | 223 |
| |
227 | 224 |
| |
228 |
| - | |
229 |
| - | |
230 |
| - | |
231 |
| - | |
| 225 | + | |
232 | 226 |
| |
233 | 227 |
| |
234 | 228 |
| |
235 |
| - | |
236 |
| - | |
237 |
| - | |
238 |
| - | |
| 229 | + | |
239 | 230 |
| |
240 | 231 |
| |
241 | 232 |
| |
242 | 233 |
| |
243 |
| - | |
244 |
| - | |
| 234 | + | |
| 235 | + | |
245 | 236 |
| |
246 | 237 |
| |
247 | 238 |
| |
|
Lines changed: 12 additions & 7 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
61 | 61 |
| |
62 | 62 |
| |
63 | 63 |
| |
64 |
| - | |
| 64 | + | |
65 | 65 |
| |
66 | 66 |
| |
67 | 67 |
| |
| |||
1270 | 1270 |
| |
1271 | 1271 |
| |
1272 | 1272 |
| |
1273 |
| - | |
1274 |
| - | |
1275 |
| - | |
| 1273 | + | |
| 1274 | + | |
1276 | 1275 |
| |
1277 | 1276 |
| |
1278 | 1277 |
| |
1279 | 1278 |
| |
1280 |
| - | |
1281 |
| - | |
1282 |
| - | |
| 1279 | + | |
| 1280 | + | |
1283 | 1281 |
| |
1284 | 1282 |
| |
1285 | 1283 |
| |
| |||
1519 | 1517 |
| |
1520 | 1518 |
| |
1521 | 1519 |
| |
| 1520 | + | |
| 1521 | + | |
| 1522 | + | |
| 1523 | + | |
| 1524 | + | |
| 1525 | + | |
| 1526 | + | |
1522 | 1527 |
| |
1523 | 1528 |
| |
1524 | 1529 |
| |
|
Lines changed: 3 additions & 4 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
15 | 15 |
| |
16 | 16 |
| |
17 | 17 |
| |
18 |
| - | |
| 18 | + | |
19 | 19 |
| |
20 | 20 |
| |
21 | 21 |
| |
| |||
211 | 211 |
| |
212 | 212 |
| |
213 | 213 |
| |
214 |
| - | |
215 |
| - | |
216 |
| - | |
| 214 | + | |
| 215 | + | |
217 | 216 |
| |
218 | 217 |
| |
219 | 218 |
| |
|
Lines changed: 19 additions & 21 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
8 | 8 |
| |
9 | 9 |
| |
10 | 10 |
| |
11 |
| - | |
| 11 | + | |
12 | 12 |
| |
13 | 13 |
| |
14 | 14 |
| |
| |||
156 | 156 |
| |
157 | 157 |
| |
158 | 158 |
| |
159 |
| - | |
160 |
| - | |
161 |
| - | |
162 |
| - | |
163 |
| - | |
164 |
| - | |
| 159 | + | |
| 160 | + | |
| 161 | + | |
| 162 | + | |
| 163 | + | |
| 164 | + | |
| 165 | + | |
165 | 166 |
| |
166 | 167 |
| |
167 |
| - | |
| 168 | + | |
| 169 | + | |
| 170 | + | |
| 171 | + | |
168 | 172 |
| |
169 | 173 |
| |
170 | 174 |
| |
171 | 175 |
| |
172 | 176 |
| |
173 | 177 |
| |
174 |
| - | |
175 |
| - | |
176 | 178 |
| |
177 | 179 |
| |
178 | 180 |
| |
179 | 181 |
| |
180 |
| - | |
181 |
| - | |
182 | 182 |
| |
183 | 183 |
| |
184 | 184 |
| |
185 | 185 |
| |
186 |
| - | |
187 |
| - | |
| 186 | + | |
| 187 | + | |
| 188 | + | |
188 | 189 |
| |
189 | 190 |
| |
190 | 191 |
| |
191 | 192 |
| |
192 | 193 |
| |
193 | 194 |
| |
194 | 195 |
| |
195 |
| - | |
196 |
| - | |
197 |
| - | |
198 |
| - | |
199 |
| - | |
200 | 196 |
| |
201 | 197 |
| |
202 | 198 |
| |
| 199 | + | |
203 | 200 |
| |
204 | 201 |
| |
205 | 202 |
| |
| |||
1525 | 1522 |
| |
1526 | 1523 |
| |
1527 | 1524 |
| |
1528 |
| - | |
1529 |
| - | |
| 1525 | + | |
| 1526 | + | |
| 1527 | + | |
1530 | 1528 |
| |
1531 | 1529 |
| |
1532 | 1530 |
| |
|
Lines changed: 3 additions & 4 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
21 | 21 |
| |
22 | 22 |
| |
23 | 23 |
| |
24 |
| - | |
| 24 | + | |
25 | 25 |
| |
26 | 26 |
| |
27 | 27 |
| |
| |||
267 | 267 |
| |
268 | 268 |
| |
269 | 269 |
| |
270 |
| - | |
271 |
| - | |
272 |
| - | |
| 270 | + | |
| 271 | + | |
273 | 272 |
| |
274 | 273 |
| |
275 | 274 |
| |
|
Lines changed: 3 additions & 4 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
8 | 8 |
| |
9 | 9 |
| |
10 | 10 |
| |
11 |
| - | |
| 11 | + | |
12 | 12 |
| |
13 | 13 |
| |
14 | 14 |
| |
| |||
159 | 159 |
| |
160 | 160 |
| |
161 | 161 |
| |
162 |
| - | |
163 |
| - | |
164 |
| - | |
| 162 | + | |
| 163 | + | |
165 | 164 |
| |
166 | 165 |
| |
167 | 166 |
| |
|
Lines changed: 13 additions & 3 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
15 | 15 |
| |
16 | 16 |
| |
17 | 17 |
| |
18 |
| - | |
| 18 | + | |
19 | 19 |
| |
20 | 20 |
| |
21 | 21 |
| |
| |||
439 | 439 |
| |
440 | 440 |
| |
441 | 441 |
| |
| 442 | + | |
442 | 443 |
| |
443 | 444 |
| |
444 | 445 |
| |
| |||
449 | 450 |
| |
450 | 451 |
| |
451 | 452 |
| |
452 |
| - | |
453 |
| - | |
| 453 | + | |
| 454 | + | |
| 455 | + | |
| 456 | + | |
454 | 457 |
| |
455 | 458 |
| |
456 | 459 |
| |
| |||
528 | 531 |
| |
529 | 532 |
| |
530 | 533 |
| |
| 534 | + | |
531 | 535 |
| |
532 | 536 |
| |
533 | 537 |
| |
| |||
545 | 549 |
| |
546 | 550 |
| |
547 | 551 |
| |
| 552 | + | |
548 | 553 |
| |
| 554 | + | |
| 555 | + | |
549 | 556 |
| |
550 | 557 |
| |
551 | 558 |
| |
| |||
569 | 576 |
| |
570 | 577 |
| |
571 | 578 |
| |
| 579 | + | |
572 | 580 |
| |
573 | 581 |
| |
574 | 582 |
| |
| |||
612 | 620 |
| |
613 | 621 |
| |
614 | 622 |
| |
| 623 | + | |
615 | 624 |
| |
616 | 625 |
| |
617 | 626 |
| |
| |||
1356 | 1365 |
| |
1357 | 1366 |
| |
1358 | 1367 |
| |
| 1368 | + | |
1359 | 1369 |
| |
1360 | 1370 |
| |
1361 | 1371 |
| |
|
Lines changed: 2 additions & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
18 | 18 |
| |
19 | 19 |
| |
20 | 20 |
| |
21 |
| - | |
| 21 | + | |
22 | 22 |
| |
23 | 23 |
| |
24 | 24 |
| |
| |||
638 | 638 |
| |
639 | 639 |
| |
640 | 640 |
| |
| 641 | + | |
641 | 642 |
| |
642 | 643 |
| |
643 | 644 |
| |
|
0 commit comments
Comments
(0)