File tree
11 files changed
+124
-49
lines changed- src
- languages
- flink
- hive
- impala
- mysql
- pgsql
- spark
- trino
11 files changed
+124
-49
lines changedLines changed: 28 additions & 10 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
3 | 5 |
| |
4 | 6 |
| |
5 | 7 |
| |
| |||
13 | 15 |
| |
14 | 16 |
| |
15 | 17 |
| |
16 |
| - | |
| 18 | + | |
17 | 19 |
| |
18 | 20 |
| |
19 | 21 |
| |
| |||
203 | 205 |
| |
204 | 206 |
| |
205 | 207 |
| |
206 |
| - | |
| 208 | + | |
| 209 | + | |
| 210 | + | |
207 | 211 |
| |
208 | 212 |
| |
209 |
| - | |
| 213 | + | |
| 214 | + | |
210 | 215 |
| |
211 | 216 |
| |
212 | 217 |
| |
213 | 218 |
| |
214 | 219 |
| |
215 | 220 |
| |
216 |
| - | |
| 221 | + | |
| 222 | + | |
| 223 | + | |
| 224 | + | |
| 225 | + | |
217 | 226 |
| |
218 | 227 |
| |
219 | 228 |
| |
| |||
249 | 258 |
| |
250 | 259 |
| |
251 | 260 |
| |
252 |
| - | |
| 261 | + | |
| 262 | + | |
| 263 | + | |
| 264 | + | |
253 | 265 |
| |
254 | 266 |
| |
255 |
| - | |
| 267 | + | |
| 268 | + | |
| 269 | + | |
256 | 270 |
| |
257 | 271 |
| |
258 | 272 |
| |
259 |
| - | |
| 273 | + | |
260 | 274 |
| |
261 | 275 |
| |
262 |
| - | |
| 276 | + | |
| 277 | + | |
| 278 | + | |
| 279 | + | |
| 280 | + | |
263 | 281 |
| |
264 | 282 |
| |
265 | 283 |
| |
| |||
279 | 297 |
| |
280 | 298 |
| |
281 | 299 |
| |
282 |
| - | |
| 300 | + | |
283 | 301 |
| |
284 | 302 |
| |
285 | 303 |
|
Lines changed: 4 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
4 | 4 |
| |
5 | 5 |
| |
6 | 6 |
| |
7 |
| - | |
8 | 7 |
| |
| 8 | + | |
9 | 9 |
| |
10 | 10 |
| |
11 | 11 |
| |
| |||
16 | 16 |
| |
17 | 17 |
| |
18 | 18 |
| |
19 |
| - | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
20 | 22 |
|
Lines changed: 4 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
4 | 4 |
| |
5 | 5 |
| |
6 | 6 |
| |
7 |
| - | |
8 | 7 |
| |
| 8 | + | |
9 | 9 |
| |
10 | 10 |
| |
11 | 11 |
| |
| |||
16 | 16 |
| |
17 | 17 |
| |
18 | 18 |
| |
19 |
| - | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
20 | 22 |
|
Lines changed: 4 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
4 | 4 |
| |
5 | 5 |
| |
6 | 6 |
| |
7 |
| - | |
8 | 7 |
| |
| 8 | + | |
9 | 9 |
| |
10 | 10 |
| |
11 | 11 |
| |
| |||
16 | 16 |
| |
17 | 17 |
| |
18 | 18 |
| |
19 |
| - | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
20 | 22 |
|
Lines changed: 4 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
4 | 4 |
| |
5 | 5 |
| |
6 | 6 |
| |
7 |
| - | |
8 | 7 |
| |
| 8 | + | |
9 | 9 |
| |
10 | 10 |
| |
11 | 11 |
| |
| |||
16 | 16 |
| |
17 | 17 |
| |
18 | 18 |
| |
19 |
| - | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
20 | 22 |
|
Lines changed: 4 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
4 | 4 |
| |
5 | 5 |
| |
6 | 6 |
| |
7 |
| - | |
8 | 7 |
| |
| 8 | + | |
9 | 9 |
| |
10 | 10 |
| |
11 | 11 |
| |
| |||
16 | 16 |
| |
17 | 17 |
| |
18 | 18 |
| |
19 |
| - | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
20 | 22 |
|
Lines changed: 4 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
4 | 4 |
| |
5 | 5 |
| |
6 | 6 |
| |
7 |
| - | |
8 | 7 |
| |
| 8 | + | |
9 | 9 |
| |
10 | 10 |
| |
11 | 11 |
| |
| |||
16 | 16 |
| |
17 | 17 |
| |
18 | 18 |
| |
19 |
| - | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
20 | 22 |
|
Lines changed: 4 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 |
| - | |
3 | 2 |
| |
| 3 | + | |
4 | 4 |
| |
5 | 5 |
| |
6 | 6 |
| |
| |||
11 | 11 |
| |
12 | 12 |
| |
13 | 13 |
| |
14 |
| - | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
15 | 17 |
|
Lines changed: 18 additions & 5 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 |
| - | |
2 |
| - | |
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
3 | 14 |
| |
4 | 15 |
| |
5 | 16 |
| |
| |||
65 | 76 |
| |
66 | 77 |
| |
67 | 78 |
| |
68 |
| - | |
| 79 | + | |
69 | 80 |
| |
70 | 81 |
| |
71 | 82 |
| |
| |||
75 | 86 |
| |
76 | 87 |
| |
77 | 88 |
| |
78 |
| - | |
| 89 | + | |
79 | 90 |
| |
80 | 91 |
| |
81 | 92 |
| |
| |||
171 | 182 |
| |
172 | 183 |
| |
173 | 184 |
| |
174 |
| - | |
| 185 | + | |
| 186 | + | |
| 187 | + | |
175 | 188 |
|
Lines changed: 27 additions & 6 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
| 1 | + | |
1 | 2 |
| |
2 |
| - | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
3 | 8 |
| |
4 | 9 |
| |
5 |
| - | |
6 | 10 |
| |
7 |
| - | |
| 11 | + | |
| 12 | + | |
8 | 13 |
| |
9 |
| - | |
10 |
| - | |
11 | 14 |
| |
12 | 15 |
| |
13 | 16 |
| |
| |||
20 | 23 |
| |
21 | 24 |
| |
22 | 25 |
| |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
23 | 34 |
| |
24 | 35 |
| |
25 | 36 |
| |
| |||
110 | 121 |
| |
111 | 122 |
| |
112 | 123 |
| |
| 124 | + | |
| 125 | + | |
| 126 | + | |
| 127 | + | |
| 128 | + | |
| 129 | + | |
| 130 | + | |
| 131 | + | |
113 | 132 |
| |
114 | 133 |
| |
115 | 134 |
| |
116 | 135 |
| |
117 | 136 |
| |
118 | 137 |
| |
119 | 138 |
| |
120 |
| - | |
| 139 | + | |
| 140 | + | |
| 141 | + | |
121 | 142 |
| |
122 | 143 |
|
0 commit comments