Commit b2fb28a
File tree
1,326 files changed
+33783
-11757
lines changed- R
- pkg
- R
- inst/worker
- tests/fulltests
- common
- network-common/src/main/java/org/apache/spark/network/protocol
- network-shuffle/src
- main/java/org/apache/spark/network/shuffle
- protocol
- test/java/org/apache/spark/network/shuffle
- 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
- rest
- security
- worker
- ui
- executor
- input
- internal
- config
- io
- memory
- metrics
- sink
- network/netty
- partial
- rdd
- rpc
- netty
- 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
- 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
- _plugins
- 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
- docker-integration-tests
- src/test/scala/org/apache/spark/sql/jdbc
- 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/scala/org/apache/spark
- mllib
- classification
- evaluation
- feature
- linalg
- distributed
- random
- rdd
- recommendation
- regression
- tree
- util
- ml
- classification
- evaluation
- feature
- regression
- tree/impl
- util
- project
- python
- pyspark
- mllib
- ml
- param
- tests
- sql
- tests
- testing
- 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
- features
- submit
- 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
- dsl
- expressions
- aggregate
- postgreSQL
- xml
- json
- optimizer
- parser
- plans/logical
- sql
- trees
- util
- postgreSQL
- connector/catalog
- execution
- internal
- types
- test/scala/org/apache/spark/sql
- catalyst
- analysis
- catalog
- csv
- encoders
- expressions
- aggregate
- codegen
- postgreSQL
- json
- optimizer
- parser
- plans
- trees
- util
- connector
- catalog
- types
- core
- benchmarks
- src
- main
- java/org/apache/spark/sql/execution
- scala/org/apache/spark/sql
- catalyst/analysis
- execution
- adaptive
- columnar
- command
- datasources
- jdbc
- parquet
- v2
- parquet
- exchange
- joins
- python
- streaming
- continuous
- ui
- window
- internal
- streaming
- test
- java/test/org/apache/spark/sql
- resources
- sql-tests
- inputs
- postgreSQL
- subquery/in-subquery
- udf/postgreSQL
- results
- pgSQL
- postgreSQL
- subquery/in-subquery
- udf
- postgreSQL
- test-data
- scala/org/apache/spark/sql
- connector
- execution
- adaptive
- aggregate
- benchmark
- columnar
- compression
- command
- datasources
- csv
- json
- noop
- orc
- parquet
- 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
- v1.2.1
- if
- src/main/java/org/apache/hive/service/cli/operation
- v2.3.5
- if
- src/main/java/org/apache/hive/service/cli/operation
- hive
- compatibility/src/test/scala/org/apache/spark/sql/hive/execution
- src
- main/scala/org/apache/spark/sql/hive
- client
- execution
- test
- resources/ql/src/test/queries/clientpositive
- scala/org/apache/spark/sql/hive
- client
- execution
- orc
- 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,326 files changed
+33783
-11757
lines changed| 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 | | |
399 | 447 | | |
| |||
410 | 458 | | |
411 | 459 | | |
412 | 460 | | |
| 461 | + | |
413 | 462 | | |
414 | 463 | | |
415 | 464 | | |
| |||
435 | 484 | | |
436 | 485 | | |
437 | 486 | | |
| 487 | + | |
438 | 488 | | |
439 | 489 | | |
440 | 490 | | |
| |||
464 | 514 | | |
465 | 515 | | |
466 | 516 | | |
| 517 | + | |
467 | 518 | | |
468 | 519 | | |
469 | 520 | | |
470 | 521 | | |
471 | 522 | | |
472 | 523 | | |
473 | 524 | | |
| 525 | + | |
474 | 526 | | |
475 | 527 | | |
476 | 528 | | |
| |||
492 | 544 | | |
493 | 545 | | |
494 | 546 | | |
| 547 | + | |
495 | 548 | | |
496 | 549 | | |
497 | 550 | | |
| |||
501 | 554 | | |
502 | 555 | | |
503 | 556 | | |
| 557 | + | |
504 | 558 | | |
505 | 559 | | |
506 | 560 | | |
| |||
0 commit comments