File tree
19 files changed
+292
-318
lines changed- src/query
- service/src
- interpreters
- pipelines/builders
- schedulers/fragments
- sql/src
- executor
- physical_plans
- planner
- binder
- optimizer
- distributed
- plans
- storages/fuse/src/operations/merge_into/mutator
- tests/sqllogictests/suites
- base/09_fuse_engine
- mode/cluster
19 files changed
+292
-318
lines changedLines changed: 21 additions & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
30 | 30 |
| |
31 | 31 |
| |
32 | 32 |
| |
| 33 | + | |
33 | 34 |
| |
34 | 35 |
| |
35 | 36 |
| |
| |||
40 | 41 |
| |
41 | 42 |
| |
42 | 43 |
| |
| 44 | + | |
43 | 45 |
| |
44 | 46 |
| |
45 | 47 |
| |
| |||
191 | 193 |
| |
192 | 194 |
| |
193 | 195 |
| |
194 |
| - | |
| 196 | + | |
195 | 197 |
| |
196 | 198 |
| |
197 | 199 |
| |
| |||
216 | 218 |
| |
217 | 219 |
| |
218 | 220 |
| |
| 221 | + | |
219 | 222 |
| |
220 | 223 |
| |
221 | 224 |
| |
| |||
563 | 566 |
| |
564 | 567 |
| |
565 | 568 |
| |
| 569 | + | |
| 570 | + | |
| 571 | + | |
| 572 | + | |
| 573 | + | |
| 574 | + | |
| 575 | + | |
| 576 | + | |
| 577 | + | |
| 578 | + | |
| 579 | + | |
| 580 | + | |
| 581 | + | |
| 582 | + | |
| 583 | + | |
| 584 | + | |
| 585 | + | |
566 | 586 |
|
Lines changed: 5 additions & 3 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
339 | 339 |
| |
340 | 340 |
| |
341 | 341 |
| |
342 |
| - | |
343 |
| - | |
344 |
| - | |
| 342 | + | |
| 343 | + | |
| 344 | + | |
| 345 | + | |
| 346 | + | |
345 | 347 |
| |
346 | 348 |
| |
347 | 349 |
| |
|
Lines changed: 17 additions & 33 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
45 | 45 |
| |
46 | 46 |
| |
47 | 47 |
| |
48 |
| - | |
49 | 48 |
| |
50 | 49 |
| |
51 | 50 |
| |
| |||
60 | 59 |
| |
61 | 60 |
| |
62 | 61 |
| |
63 |
| - | |
64 | 62 |
| |
65 | 63 |
| |
66 | 64 |
| |
| |||
74 | 72 |
| |
75 | 73 |
| |
76 | 74 |
| |
77 |
| - | |
78 |
| - | |
| 75 | + | |
| 76 | + | |
79 | 77 |
| |
80 | 78 |
| |
81 | 79 |
| |
| |||
125 | 123 |
| |
126 | 124 |
| |
127 | 125 |
| |
128 |
| - | |
| 126 | + | |
129 | 127 |
| |
130 | 128 |
| |
131 | 129 |
| |
| |||
145 | 143 |
| |
146 | 144 |
| |
147 | 145 |
| |
| 146 | + | |
148 | 147 |
| |
149 | 148 |
| |
| 149 | + | |
150 | 150 |
| |
151 | 151 |
| |
152 | 152 |
| |
| |||
211 | 211 |
| |
212 | 212 |
| |
213 | 213 |
| |
214 |
| - | |
215 |
| - | |
216 |
| - | |
217 |
| - | |
218 |
| - | |
219 |
| - | |
220 |
| - | |
221 |
| - | |
222 | 214 |
| |
223 |
| - | |
| 215 | + | |
224 | 216 |
| |
225 | 217 |
| |
226 | 218 |
| |
| |||
265 | 257 |
| |
266 | 258 |
| |
267 | 259 |
| |
268 |
| - | |
| 260 | + | |
269 | 261 |
| |
270 | 262 |
| |
271 | 263 |
| |
| |||
276 | 268 |
| |
277 | 269 |
| |
278 | 270 |
| |
279 |
| - | |
| 271 | + | |
280 | 272 |
| |
281 | 273 |
| |
282 | 274 |
| |
| |||
285 | 277 |
| |
286 | 278 |
| |
287 | 279 |
| |
288 |
| - | |
289 |
| - | |
290 |
| - | |
291 |
| - | |
292 |
| - | |
293 |
| - | |
294 |
| - | |
295 |
| - | |
296 |
| - | |
297 |
| - | |
298 |
| - | |
299 | 280 |
| |
300 | 281 |
| |
301 | 282 |
| |
| |||
432 | 413 |
| |
433 | 414 |
| |
434 | 415 |
| |
| 416 | + | |
435 | 417 |
| |
436 | 418 |
| |
437 | 419 |
| |
| |||
444 | 426 |
| |
445 | 427 |
| |
446 | 428 |
| |
447 |
| - | |
448 |
| - | |
449 |
| - | |
450 |
| - | |
451 |
| - | |
| 429 | + | |
| 430 | + | |
| 431 | + | |
| 432 | + | |
| 433 | + | |
| 434 | + | |
452 | 435 |
| |
453 | 436 |
| |
454 | 437 |
| |
455 | 438 |
| |
456 |
| - | |
| 439 | + | |
457 | 440 |
| |
458 | 441 |
| |
459 | 442 |
| |
460 | 443 |
| |
461 | 444 |
| |
462 | 445 |
| |
463 | 446 |
| |
| 447 | + | |
464 | 448 |
| |
465 | 449 |
| |
466 | 450 |
| |
|
Lines changed: 15 additions & 15 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
143 | 143 |
| |
144 | 144 |
| |
145 | 145 |
| |
146 |
| - | |
| 146 | + | |
147 | 147 |
| |
148 | 148 |
| |
149 | 149 |
| |
| |||
291 | 291 |
| |
292 | 292 |
| |
293 | 293 |
| |
| 294 | + | |
294 | 295 |
| |
295 | 296 |
| |
296 | 297 |
| |
| |||
366 | 367 |
| |
367 | 368 |
| |
368 | 369 |
| |
| 370 | + | |
369 | 371 |
| |
370 | 372 |
| |
371 |
| - | |
| 373 | + | |
372 | 374 |
| |
373 | 375 |
| |
374 | 376 |
| |
| |||
457 | 459 |
| |
458 | 460 |
| |
459 | 461 |
| |
460 |
| - | |
461 |
| - | |
462 |
| - | |
463 |
| - | |
| 462 | + | |
| 463 | + | |
464 | 464 |
| |
465 | 465 |
| |
466 | 466 |
| |
| |||
613 | 613 |
| |
614 | 614 |
| |
615 | 615 |
| |
616 |
| - | |
| 616 | + | |
617 | 617 |
| |
618 | 618 |
| |
619 | 619 |
| |
| |||
624 | 624 |
| |
625 | 625 |
| |
626 | 626 |
| |
627 |
| - | |
| 627 | + | |
628 | 628 |
| |
629 | 629 |
| |
630 | 630 |
| |
| |||
659 | 659 |
| |
660 | 660 |
| |
661 | 661 |
| |
662 |
| - | |
| 662 | + | |
663 | 663 |
| |
664 | 664 |
| |
665 | 665 |
| |
| |||
721 | 721 |
| |
722 | 722 |
| |
723 | 723 |
| |
724 |
| - | |
| 724 | + | |
725 | 725 |
| |
726 | 726 |
| |
727 | 727 |
| |
| |||
773 | 773 |
| |
774 | 774 |
| |
775 | 775 |
| |
776 |
| - | |
| 776 | + | |
777 | 777 |
| |
778 | 778 |
| |
779 | 779 |
| |
| |||
817 | 817 |
| |
818 | 818 |
| |
819 | 819 |
| |
820 |
| - | |
| 820 | + | |
821 | 821 |
| |
822 | 822 |
| |
823 | 823 |
| |
| |||
853 | 853 |
| |
854 | 854 |
| |
855 | 855 |
| |
856 |
| - | |
| 856 | + | |
857 | 857 |
| |
858 | 858 |
| |
859 | 859 |
| |
| |||
877 | 877 |
| |
878 | 878 |
| |
879 | 879 |
| |
880 |
| - | |
| 880 | + | |
881 | 881 |
| |
882 | 882 |
| |
883 | 883 |
| |
| |||
911 | 911 |
| |
912 | 912 |
| |
913 | 913 |
| |
914 |
| - | |
| 914 | + | |
915 | 915 |
| |
916 | 916 |
| |
917 | 917 |
| |
|
Lines changed: 0 additions & 4 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
162 | 162 |
| |
163 | 163 |
| |
164 | 164 |
| |
165 |
| - | |
166 |
| - | |
167 |
| - | |
168 | 165 |
| |
169 | 166 |
| |
170 | 167 |
| |
| |||
232 | 229 |
| |
233 | 230 |
| |
234 | 231 |
| |
235 |
| - | |
236 | 232 |
| |
237 | 233 |
| |
238 | 234 |
| |
|
0 commit comments