Commit 3108da2
authored
Merge branch 'master' into SPARK-29145
File tree
1,228 files changed
+23604
-9066
lines changed- .github/workflows
- R
- pkg
- R
- inst/worker
- tests/fulltests
- build
- common
- kvstore/src/main/java/org/apache/spark/util/kvstore
- network-common/src
- main/java/org/apache/spark/network
- client
- protocol
- test/java/org/apache/spark/network
- network-shuffle/src
- main/java/org/apache/spark/network/shuffle
- protocol
- test/java/org/apache/spark/network/shuffle
- tags/src/test/java/org/apache/spark/tags
- unsafe/src
- main/java/org/apache/spark/unsafe/types
- test
- java/org/apache/spark/unsafe/types
- scala/org/apache/spark/unsafe/types
- core
- benchmarks
- src
- main
- java/org/apache/spark
- memory
- shuffle
- api
- sort
- io
- unsafe/map
- resources/org/apache/spark/ui/static
- scala/org/apache/spark
- api
- java
- python
- r
- broadcast
- deploy
- client
- history
- master
- ui
- worker
- ui
- executor
- input
- internal
- config
- io
- memory
- metrics
- sink
- network/netty
- partial
- rdd
- scheduler
- cluster
- dynalloc
- local
- serializer
- shuffle
- sort
- status
- api/v1
- storage
- ui
- util
- collection
- logging
- random
- test
- java
- org/apache/spark
- shuffle/sort
- unsafe/map
- util
- collection/unsafe/sort
- test/org/apache/spark
- scala/org/apache/spark
- benchmark
- broadcast
- deploy
- client
- history
- master
- ui
- rest
- security
- worker
- ui
- executor
- input
- io
- memory
- metrics
- network/netty
- rdd
- resource
- rpc
- netty
- scheduler
- dynalloc
- security
- serializer
- shuffle
- sort
- io
- status
- storage
- ui
- util
- collection
- unsafe/sort
- logging
- dev
- deps
- sparktestsupport
- docs
- _data
- examples
- src/main/scala/org/apache/spark/examples
- graphx
- mllib
- ml
- sql
- hive
- streaming
- streaming
- clickstream
- external
- avro
- benchmarks
- src/test/scala/org/apache/spark/sql/avro
- kafka-0-10-sql
- src
- main/scala/org/apache/spark/sql/kafka010
- test/scala/org/apache/spark/sql/kafka010
- kafka-0-10-token-provider/src
- main/scala/org/apache/spark/kafka010
- test/scala/org/apache/spark/kafka010
- kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010
- mocks
- kinesis-asl/src
- main/scala/org/apache/spark
- examples/streaming
- streaming/kinesis
- test/scala/org/apache/spark/streaming/kinesis
- graphx/src
- main/scala/org/apache/spark/graphx
- impl
- lib
- util
- collection
- test/scala/org/apache/spark/graphx
- lib
- launcher/src
- main/java/org/apache/spark/launcher
- test/java/org/apache/spark/launcher
- licenses-binary
- mllib-local/src
- main/scala/org/apache/spark/ml/linalg
- test/scala/org/apache/spark/ml/linalg
- mllib
- benchmarks
- src
- main/scala/org/apache/spark
- mllib
- api/python
- clustering
- evaluation
- linalg
- distributed
- random
- util
- ml
- classification
- evaluation
- feature
- recommendation
- regression
- tree/impl
- util
- test
- java/org/apache/spark/ml/feature
- scala/org/apache/spark
- mllib
- classification
- feature
- linalg
- distributed
- random
- rdd
- recommendation
- regression
- tree
- util
- ml
- classification
- evaluation
- feature
- regression
- tree/impl
- util
- project
- python
- pyspark
- ml
- tests
- sql
- tests
- tests
- repl/src
- main/scala/org/apache/spark/repl
- test/scala/org/apache/spark/repl
- resource-managers
- kubernetes
- core/src
- main/scala/org/apache/spark
- deploy/k8s
- scheduler/cluster/k8s
- test/scala/org/apache/spark/deploy/k8s
- submit
- docker/src/main/dockerfiles/spark
- bindings
- R
- python
- integration-tests
- scripts
- src/test/scala/org/apache/spark/deploy/k8s/integrationtest
- mesos/src
- main/scala/org/apache/spark
- deploy/mesos
- ui
- executor
- scheduler/cluster/mesos
- test/scala/org/apache/spark
- deploy/rest/mesos
- scheduler/cluster/mesos
- yarn/src
- main/scala/org/apache/spark
- deploy/yarn
- scheduler/cluster
- test/scala/org/apache/spark
- deploy/yarn
- scheduler/cluster
- sql
- catalyst
- benchmarks
- src
- main
- antlr4/org/apache/spark/sql/catalyst/parser
- java/org/apache/spark/sql
- catalyst/expressions
- connector/catalog
- scala/org/apache/spark/sql
- catalyst
- analysis
- catalog
- csv
- encoders
- expressions
- aggregate
- codegen
- postgreSQL
- xml
- json
- optimizer
- parser
- plans/logical
- sql
- trees
- util
- postgreSQL
- connector/catalog
- execution/datasources/v2
- internal
- test/scala/org/apache/spark/sql
- catalyst
- analysis
- catalog
- csv
- encoders
- expressions
- aggregate
- codegen
- postgreSQL
- optimizer
- parser
- plans
- trees
- util
- connector
- catalog
- types
- util
- core
- benchmarks
- src
- main/scala/org/apache/spark/sql
- catalyst/analysis
- execution
- aggregate
- columnar
- command
- datasources
- jdbc
- orc
- parquet
- v2
- orc
- parquet
- exchange
- python
- streaming
- continuous
- window
- internal
- test
- java/test/org/apache/spark/sql
- resources/sql-tests
- inputs
- ansi
- postgreSQL
- subquery/in-subquery
- udf/postgreSQL
- results
- ansi
- postgreSQL
- subquery/in-subquery
- udf/postgreSQL
- scala/org/apache/spark/sql
- connector
- execution
- aggregate
- benchmark
- columnar
- compression
- command
- datasources
- csv
- json
- noop
- orc
- parquet
- metric
- python
- streaming
- sources
- state
- ui
- vectorized
- jdbc
- sources
- streaming
- continuous
- test
- util
- test
- util
- hive-thriftserver
- src
- main/scala/org/apache/spark/sql/hive/thriftserver
- ui
- test/scala/org/apache/spark/sql/hive/thriftserver
- hive
- compatibility/src/test/scala/org/apache/spark/sql/hive/execution
- src
- main/scala/org/apache/spark/sql/hive
- client
- test/scala/org/apache/spark/sql/hive
- client
- execution
- test
- streaming
- src
- main/scala/org/apache/spark/streaming
- api
- java
- python
- dstream
- receiver
- scheduler
- ui
- util
- test/scala/org/apache/spark/streaming
- rdd
- scheduler
- util
- tools
- src/main/scala/org/apache/spark/tools
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
1,228 files changed
+23604
-9066
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
26 | 26 | | |
27 | 27 | | |
28 | 28 | | |
29 | | - | |
| 29 | + | |
30 | 30 | | |
31 | 31 | | |
32 | | - | |
| 32 | + | |
33 | 33 | | |
34 | 34 | | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
243 | 243 | | |
244 | 244 | | |
245 | 245 | | |
246 | | - | |
| 246 | + | |
247 | 247 | | |
248 | 248 | | |
249 | 249 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
218 | 218 | | |
219 | 219 | | |
220 | 220 | | |
| 221 | + | |
221 | 222 | | |
222 | 223 | | |
223 | 224 | | |
224 | 225 | | |
225 | 226 | | |
226 | 227 | | |
227 | | - | |
| 228 | + | |
228 | 229 | | |
229 | 230 | | |
230 | 231 | | |
| |||
253 | 254 | | |
254 | 255 | | |
255 | 256 | | |
| 257 | + | |
256 | 258 | | |
257 | 259 | | |
258 | 260 | | |
259 | 261 | | |
260 | 262 | | |
261 | 263 | | |
| 264 | + | |
262 | 265 | | |
263 | 266 | | |
264 | 267 | | |
265 | 268 | | |
266 | 269 | | |
267 | 270 | | |
268 | 271 | | |
| 272 | + | |
269 | 273 | | |
270 | 274 | | |
271 | 275 | | |
| |||
278 | 282 | | |
279 | 283 | | |
280 | 284 | | |
| 285 | + | |
| 286 | + | |
| 287 | + | |
| 288 | + | |
| 289 | + | |
| 290 | + | |
| 291 | + | |
| 292 | + | |
| 293 | + | |
| 294 | + | |
| 295 | + | |
| 296 | + | |
| 297 | + | |
| 298 | + | |
| 299 | + | |
281 | 300 | | |
282 | 301 | | |
283 | 302 | | |
| |||
292 | 311 | | |
293 | 312 | | |
294 | 313 | | |
| 314 | + | |
| 315 | + | |
295 | 316 | | |
296 | 317 | | |
297 | 318 | | |
| 319 | + | |
298 | 320 | | |
| 321 | + | |
299 | 322 | | |
300 | 323 | | |
| 324 | + | |
| 325 | + | |
301 | 326 | | |
302 | 327 | | |
| 328 | + | |
303 | 329 | | |
304 | 330 | | |
| 331 | + | |
305 | 332 | | |
306 | 333 | | |
307 | 334 | | |
| |||
313 | 340 | | |
314 | 341 | | |
315 | 342 | | |
| 343 | + | |
| 344 | + | |
316 | 345 | | |
317 | 346 | | |
318 | 347 | | |
| |||
328 | 357 | | |
329 | 358 | | |
330 | 359 | | |
| 360 | + | |
331 | 361 | | |
332 | 362 | | |
333 | 363 | | |
| |||
343 | 373 | | |
344 | 374 | | |
345 | 375 | | |
346 | | - | |
347 | | - | |
348 | | - | |
349 | | - | |
350 | | - | |
351 | 376 | | |
352 | 377 | | |
353 | 378 | | |
| |||
369 | 394 | | |
370 | 395 | | |
371 | 396 | | |
| 397 | + | |
| 398 | + | |
| 399 | + | |
| 400 | + | |
| 401 | + | |
| 402 | + | |
| 403 | + | |
| 404 | + | |
| 405 | + | |
| 406 | + | |
| 407 | + | |
| 408 | + | |
| 409 | + | |
| 410 | + | |
| 411 | + | |
| 412 | + | |
| 413 | + | |
| 414 | + | |
| 415 | + | |
| 416 | + | |
| 417 | + | |
372 | 418 | | |
373 | 419 | | |
374 | 420 | | |
| |||
387 | 433 | | |
388 | 434 | | |
389 | 435 | | |
| 436 | + | |
390 | 437 | | |
391 | 438 | | |
392 | 439 | | |
393 | 440 | | |
394 | 441 | | |
395 | 442 | | |
396 | 443 | | |
| 444 | + | |
397 | 445 | | |
398 | 446 | | |
| 447 | + | |
| 448 | + | |
399 | 449 | | |
400 | 450 | | |
401 | 451 | | |
| |||
408 | 458 | | |
409 | 459 | | |
410 | 460 | | |
| 461 | + | |
411 | 462 | | |
412 | 463 | | |
413 | 464 | | |
| |||
433 | 484 | | |
434 | 485 | | |
435 | 486 | | |
436 | | - | |
437 | | - | |
| 487 | + | |
| 488 | + | |
| 489 | + | |
| 490 | + | |
| 491 | + | |
| 492 | + | |
| 493 | + | |
438 | 494 | | |
439 | 495 | | |
440 | 496 | | |
| |||
458 | 514 | | |
459 | 515 | | |
460 | 516 | | |
| 517 | + | |
461 | 518 | | |
462 | 519 | | |
463 | 520 | | |
464 | 521 | | |
465 | 522 | | |
466 | 523 | | |
467 | 524 | | |
| 525 | + | |
468 | 526 | | |
469 | 527 | | |
470 | 528 | | |
| |||
495 | 553 | | |
496 | 554 | | |
497 | 555 | | |
498 | | - | |
499 | | - | |
500 | | - | |
501 | | - | |
502 | | - | |
| 556 | + | |
503 | 557 | | |
504 | 558 | | |
505 | 559 | | |
| |||
0 commit comments