File tree
43 files changed
+912
-303
lines changed- datafusion
- core
- src
- datasource
- file_format
- listing
- physical_plan
- test
- test_util
- tests
- fuzz_cases
- memory_limit
- parquet
- physical_optimizer
- datasource/src
- datasource-avro/src
- datasource-csv/src
- datasource-json/src
- datasource-parquet/src
- proto
- src/physical_plan
- tests/cases
- substrait
- src/physical_plan
- tests/cases
- datafusion-examples/examples
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
43 files changed
+912
-303
lines changedLines changed: 9 additions & 6 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
30 | 30 |
| |
31 | 31 |
| |
32 | 32 |
| |
33 |
| - | |
| 33 | + | |
34 | 34 |
| |
35 | 35 |
| |
36 | 36 |
| |
| |||
55 | 55 |
| |
56 | 56 |
| |
57 | 57 |
| |
| 58 | + | |
58 | 59 |
| |
59 | 60 |
| |
60 | 61 |
| |
| |||
498 | 499 |
| |
499 | 500 |
| |
500 | 501 |
| |
501 |
| - | |
502 |
| - | |
503 |
| - | |
504 |
| - | |
| 502 | + | |
| 503 | + | |
| 504 | + | |
| 505 | + | |
| 506 | + | |
| 507 | + | |
505 | 508 |
| |
506 | 509 |
| |
507 |
| - | |
| 510 | + | |
508 | 511 |
| |
509 | 512 |
| |
510 | 513 |
| |
|
Lines changed: 8 additions & 7 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
24 | 24 |
| |
25 | 25 |
| |
26 | 26 |
| |
27 |
| - | |
28 |
| - | |
29 |
| - | |
| 27 | + | |
30 | 28 |
| |
31 | 29 |
| |
32 | 30 |
| |
33 | 31 |
| |
34 | 32 |
| |
35 | 33 |
| |
| 34 | + | |
36 | 35 |
| |
37 | 36 |
| |
38 | 37 |
| |
| |||
56 | 55 |
| |
57 | 56 |
| |
58 | 57 |
| |
59 |
| - | |
| 58 | + | |
60 | 59 |
| |
61 | 60 |
| |
62 | 61 |
| |
63 | 62 |
| |
64 | 63 |
| |
65 | 64 |
| |
66 |
| - | |
| 65 | + | |
| 66 | + | |
67 | 67 |
| |
68 | 68 |
| |
69 | 69 |
| |
| |||
121 | 121 |
| |
122 | 122 |
| |
123 | 123 |
| |
124 |
| - | |
| 124 | + | |
125 | 125 |
| |
126 | 126 |
| |
127 | 127 |
| |
128 | 128 |
| |
129 | 129 |
| |
130 | 130 |
| |
131 |
| - | |
| 131 | + | |
| 132 | + | |
132 | 133 |
| |
133 | 134 |
| |
134 | 135 |
| |
|
Lines changed: 10 additions & 8 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
27 | 27 |
| |
28 | 28 |
| |
29 | 29 |
| |
30 |
| - | |
| 30 | + | |
| 31 | + | |
31 | 32 |
| |
32 | 33 |
| |
33 | 34 |
| |
| |||
243 | 244 |
| |
244 | 245 |
| |
245 | 246 |
| |
246 |
| - | |
247 |
| - | |
| 247 | + | |
| 248 | + | |
248 | 249 |
| |
249 | 250 |
| |
250 | 251 |
| |
| |||
253 | 254 |
| |
254 | 255 |
| |
255 | 256 |
| |
256 |
| - | |
257 |
| - | |
258 |
| - | |
259 |
| - | |
| 257 | + | |
| 258 | + | |
| 259 | + | |
260 | 260 |
| |
261 |
| - | |
| 261 | + | |
| 262 | + | |
| 263 | + | |
262 | 264 |
| |
263 | 265 |
| |
264 | 266 |
| |
|
Lines changed: 8 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
49 | 49 |
| |
50 | 50 |
| |
51 | 51 |
| |
52 |
| - | |
| 52 | + | |
53 | 53 |
| |
54 | 54 |
| |
55 | 55 |
| |
| |||
58 | 58 |
| |
59 | 59 |
| |
60 | 60 |
| |
| 61 | + | |
61 | 62 |
| |
62 | 63 |
| |
63 | 64 |
| |
| |||
173 | 174 |
| |
174 | 175 |
| |
175 | 176 |
| |
176 |
| - | |
| 177 | + | |
| 178 | + | |
| 179 | + | |
| 180 | + | |
| 181 | + | |
| 182 | + | |
177 | 183 |
| |
178 | 184 |
| |
179 | 185 |
| |
|
Lines changed: 5 additions & 5 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
40 | 40 |
| |
41 | 41 |
| |
42 | 42 |
| |
43 |
| - | |
44 |
| - | |
45 |
| - | |
| 43 | + | |
| 44 | + | |
46 | 45 |
| |
47 | 46 |
| |
48 | 47 |
| |
| |||
79 | 78 |
| |
80 | 79 |
| |
81 | 80 |
| |
82 |
| - | |
| 81 | + | |
83 | 82 |
| |
84 | 83 |
| |
85 | 84 |
| |
86 | 85 |
| |
87 | 86 |
| |
88 | 87 |
| |
89 | 88 |
| |
90 |
| - | |
| 89 | + | |
| 90 | + | |
91 | 91 |
| |
92 | 92 |
| |
93 | 93 |
| |
|
Lines changed: 4 additions & 3 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
34 | 34 |
| |
35 | 35 |
| |
36 | 36 |
| |
37 |
| - | |
| 37 | + | |
38 | 38 |
| |
39 | 39 |
| |
40 | 40 |
| |
| |||
942 | 942 |
| |
943 | 943 |
| |
944 | 944 |
| |
945 |
| - | |
| 945 | + | |
946 | 946 |
| |
947 | 947 |
| |
948 | 948 |
| |
| |||
953 | 953 |
| |
954 | 954 |
| |
955 | 955 |
| |
956 |
| - | |
| 956 | + | |
| 957 | + | |
957 | 958 |
| |
958 | 959 |
| |
959 | 960 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
251 | 251 |
| |
252 | 252 |
| |
253 | 253 |
| |
254 |
| - | |
| 254 | + | |
255 | 255 |
| |
256 | 256 |
| |
257 | 257 |
| |
|
Lines changed: 10 additions & 5 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 |
| |
| |||
72 | 72 |
| |
73 | 73 |
| |
74 | 74 |
| |
| 75 | + | |
75 | 76 |
| |
76 | 77 |
| |
77 | 78 |
| |
| |||
128 | 129 |
| |
129 | 130 |
| |
130 | 131 |
| |
131 |
| - | |
132 |
| - | |
133 |
| - | |
| 132 | + | |
| 133 | + | |
| 134 | + | |
| 135 | + | |
| 136 | + | |
| 137 | + | |
| 138 | + | |
134 | 139 |
| |
135 |
| - | |
| 140 | + | |
136 | 141 |
| |
137 | 142 |
| |
138 | 143 |
| |
|
Lines changed: 20 additions & 13 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
33 | 33 |
| |
34 | 34 |
| |
35 | 35 |
| |
36 |
| - | |
| 36 | + | |
37 | 37 |
| |
38 | 38 |
| |
39 | 39 |
| |
40 | 40 |
| |
41 | 41 |
| |
42 | 42 |
| |
| 43 | + | |
43 | 44 |
| |
44 | 45 |
| |
45 | 46 |
| |
| |||
81 | 82 |
| |
82 | 83 |
| |
83 | 84 |
| |
84 |
| - | |
85 |
| - | |
86 |
| - | |
87 |
| - | |
88 |
| - | |
89 |
| - | |
| 85 | + | |
| 86 | + | |
| 87 | + | |
| 88 | + | |
| 89 | + | |
| 90 | + | |
| 91 | + | |
| 92 | + | |
| 93 | + | |
| 94 | + | |
90 | 95 |
| |
91 | 96 |
| |
92 | 97 |
| |
| |||
153 | 158 |
| |
154 | 159 |
| |
155 | 160 |
| |
156 |
| - | |
| 161 | + | |
157 | 162 |
| |
158 |
| - | |
| 163 | + | |
| 164 | + | |
159 | 165 |
| |
160 |
| - | |
| 166 | + | |
161 | 167 |
| |
162 | 168 |
| |
163 | 169 |
| |
| |||
222 | 228 |
| |
223 | 229 |
| |
224 | 230 |
| |
225 |
| - | |
| 231 | + | |
226 | 232 |
| |
227 | 233 |
| |
228 | 234 |
| |
229 | 235 |
| |
230 |
| - | |
| 236 | + | |
| 237 | + | |
231 | 238 |
| |
232 |
| - | |
| 239 | + | |
233 | 240 |
| |
234 | 241 |
| |
235 | 242 |
| |
|
0 commit comments