Commit 56fbf15
committed
Merge branch 'master' into SPARK-32940
File tree
2,080 files changed
+114175
-56820
lines changed- .github
- workflows
- R/pkg
- R
- tests/fulltests
- assembly
- binder
- build
- common
- kvstore
- src
- main/java/org/apache/spark/util/kvstore
- test/java/org/apache/spark/util/kvstore
- network-common
- src
- main/java/org/apache/spark/network
- client
- crypto
- protocol
- server
- util
- test/java/org/apache/spark/network
- crypto
- protocol
- sasl
- util
- network-shuffle
- src
- main/java/org/apache/spark/network/shuffle
- checksum
- protocol
- test/java/org/apache/spark/network/shuffle
- protocol
- network-yarn
- src/main/java/org/apache/spark/network/yarn
- sketch
- tags
- unsafe
- src
- main/java/org/apache/spark/unsafe
- array
- memory
- types
- test/java/org/apache/spark/unsafe/types
- conf
- core
- benchmarks
- src
- main
- java/org/apache
- hadoop/shaded/net/jpountz/lz4
- spark
- memory
- shuffle
- api
- checksum
- sort
- io
- util/collection/unsafe/sort
- resources
- error
- org/apache/spark/ui/static
- scala/org/apache/spark
- api
- java
- python
- r
- deploy
- history
- master
- security
- worker
- errors
- executor
- internal
- config
- io
- io
- mapred
- network
- netty
- rdd
- scheduler
- cluster
- dynalloc
- serializer
- shuffle
- sort
- status
- storage
- ui
- util
- collection
- io
- logging
- test
- java
- org/apache/spark
- io
- launcher
- shuffle/sort
- unsafe/map
- util/collection
- unsafe/sort
- test/org/apache/spark
- scala/org/apache/spark
- deploy
- history
- executor
- network/netty
- rdd
- scheduler
- shuffle
- sort
- io
- status
- storage
- ui
- util
- collection
- io
- dev
- ansible-for-test-node
- roles
- common
- tasks
- jenkins-worker
- defaults
- files
- python_environments
- scripts
- util_scripts
- tasks
- vars
- create-release
- spark-rm
- deps
- sparktestsupport
- docs
- _data
- img
- examples
- src/main
- java/org/apache/spark/examples
- ml
- sql
- streaming
- python
- ml
- sql/streaming
- scala/org/apache/spark/examples
- ml
- sql/streaming
- external
- avro
- src
- main/scala/org/apache/spark/sql
- avro
- v2/avro
- test/scala/org/apache/spark/sql/avro
- docker-integration-tests
- src/test/scala/org/apache/spark/sql/jdbc
- v2
- kafka-0-10-assembly
- kafka-0-10-sql
- src
- main/scala/org/apache/spark/sql/kafka010
- consumer
- test/scala/org/apache/spark/sql/kafka010
- kafka-0-10-token-provider
- src/main/scala/org/apache/spark/kafka010
- kafka-0-10
- src/test/java/org/apache/spark/streaming/kafka010
- kinesis-asl-assembly
- kinesis-asl
- src/test/scala/org/apache/spark/streaming/kinesis
- spark-ganglia-lgpl
- graphx
- src/main/scala/org/apache/spark/graphx
- util
- hadoop-cloud
- src/hadoop-3/main/scala/org/apache/spark/internal/io/cloud
- launcher
- src/main/java/org/apache/spark/launcher
- mllib-local
- src
- main/scala/org/apache/spark/ml
- impl
- linalg
- test/scala/org/apache/spark/ml/linalg
- mllib
- src
- main/scala/org/apache/spark
- mllib
- api/python
- clustering
- linalg
- distributed
- optimization
- ml
- classification
- evaluation
- feature
- optim/aggregator
- tuning
- test/scala/org/apache/spark
- mllib
- linalg
- pmml/export
- util
- ml
- optim
- source/image
- tuning
- project
- python
- docs
- source
- getting_started
- migration_guide
- reference
- pyspark.pandas
- user_guide/pandas_on_spark
- pyspark
- mllib
- tests
- ml
- linalg
- tests
- pandas
- data_type_ops
- indexes
- missing
- plot
- spark
- tests
- data_type_ops
- indexes
- typedef
- usage_logging
- sql
- pandas
- _typing/protocols
- tests
- streaming/tests
- testing
- tests
- test_coverage
- repl
- src/main/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
- features
- scheduler/cluster/k8s
- docker/src/main/dockerfiles/spark
- bindings/R
- integration-tests
- src/test/scala/org/apache/spark/deploy/k8s/integrationtest
- mesos
- src/test/scala/org/apache/spark/scheduler/cluster/mesos
- yarn
- src
- main/scala/org/apache/spark
- deploy/yarn
- scheduler/cluster
- test/scala/org/apache/spark/network/yarn
- sql
- catalyst
- benchmarks
- src
- main
- antlr4/org/apache/spark/sql/catalyst/parser
- java/org/apache/spark/sql
- catalyst/expressions
- connector
- catalog
- functions
- index
- expressions
- aggregate
- filter
- read
- streaming
- write
- types
- vectorized
- scala-2.12/org/apache/spark/sql/catalyst/expressions
- scala-2.13/org/apache/spark/sql/catalyst/expressions
- scala/org/apache/spark/sql
- catalyst
- analysis
- catalog
- csv
- dsl
- encoders
- expressions
- aggregate
- codegen
- json
- optimizer
- parser
- planning
- plans
- logical
- statsEstimation
- physical
- rules
- trees
- util
- connector/catalog
- errors
- execution
- internal
- connector
- types
- util
- test
- java/org/apache/spark/sql/catalyst/expressions
- scala/org/apache/spark/sql
- catalyst
- analysis
- catalog
- csv
- encoders
- expressions
- aggregate
- codegen
- xml
- optimizer
- parser
- planning
- plans
- statsEstimation
- trees
- util
- connector/catalog
- types
- core
- src
- main
- java/org/apache/spark/sql
- connector/write
- execution
- datasources/parquet
- vectorized
- streaming
- scala/org/apache/spark/sql
- api
- python
- r
- catalyst/analysis
- execution
- adaptive
- aggregate
- arrow
- bucketing
- columnar
- compression
- command
- datasources
- csv
- jdbc
- connection
- json
- noop
- orc
- parquet
- text
- v2
- csv
- jdbc
- json
- orc
- parquet
- text
- dynamicpruning
- exchange
- joins
- metric
- python
- streaming
- continuous
- sources
- state
- window
- expressions
- internal
- jdbc
- streaming
- util
- test
- java/test/org/apache/spark/sql
- connector
- streaming
- resources
- sql-functions
- sql-tests
- inputs
- ansi
- postgreSQL
- subquery
- exists-subquery
- in-subquery
- scalar-subquery
- timestampNTZ
- results
- ansi
- postgreSQL
- subquery
- in-subquery
- scalar-subquery
- timestampNTZ
- typeCoercion/native
- udf
- postgreSQL
- test-data
- tpcds-plan-stability
- approved-plans-modified
- q10.sf100
- q10
- q19.sf100
- q19
- q27.sf100
- q27
- q3.sf100
- q34.sf100
- q34
- q3
- q42.sf100
- q42
- q43.sf100
- q43
- q46.sf100
- q46
- q52.sf100
- q52
- q53.sf100
- q53
- q55.sf100
- q55
- q59.sf100
- q59
- q63.sf100
- q63
- q65.sf100
- q65
- q68.sf100
- q68
- q7.sf100
- q73.sf100
- q73
- q79.sf100
- q79
- q7
- q89.sf100
- q89
- q98.sf100
- q98
- approved-plans-v1_4
- q1.sf100
- q10.sf100
- q10
- q11.sf100
- q11
- q12.sf100
- q12
- q13.sf100
- q13
- q14a.sf100
- q14a
- q14b.sf100
- q14b
- q15.sf100
- q15
- q16.sf100
- q16
- q17.sf100
- q17
- q18.sf100
- q18
- q19.sf100
- q19
- q1
- q2.sf100
- q20.sf100
- q20
- q21.sf100
- q21
- q22.sf100
- q22
- q23a.sf100
- q23a
- q23b.sf100
- q23b
- q24a.sf100
- q24a
- q24b.sf100
- q24b
- q25.sf100
- q25
- q26.sf100
- q26
- q27.sf100
- q27
- q29.sf100
- q29
- q2
- q3.sf100
- q30.sf100
- q30
- q31.sf100
- q31
- q32.sf100
- q32
- q33.sf100
- q33
- q35.sf100
- q35
- q36.sf100
- q36
- q37.sf100
- q37
- q38.sf100
- q38
- q39a.sf100
- q39a
- q39b.sf100
- q39b
- q3
- q4.sf100
- q40.sf100
- q40
- q41.sf100
- q41
- q42.sf100
- q42
- q43.sf100
- q43
- q44.sf100
- q44
- q45.sf100
- q45
- q46.sf100
- q46
- q47.sf100
- q47
- q48.sf100
- q48
- q49.sf100
- q49
- q4
- q5.sf100
- q50.sf100
- q50
- q51.sf100
- q51
- q52.sf100
- q52
- q53.sf100
- q53
- q54.sf100
- q54
- q55.sf100
- q55
- q56.sf100
- q56
- q57.sf100
- q57
- q58.sf100
- q58
- q59.sf100
- q59
- q5
- q60.sf100
- q60
- q61.sf100
- q61
- q62.sf100
- q62
- q63.sf100
- q63
- q65.sf100
- q65
- q66.sf100
- q66
- q67.sf100
- q67
- q68.sf100
- q68
- q69.sf100
- q69
- q7.sf100
- q70.sf100
- q70
- q71.sf100
- q71
- q72.sf100
- q72
- q73.sf100
- q73
- q76.sf100
- q76
- q77.sf100
- q77
- q79.sf100
- q79
- q7
- q8.sf100
- q80.sf100
- q80
- q81.sf100
- q81
- q82.sf100
- q82
- q83.sf100
- q83
- q84.sf100
- q84
- q85.sf100
- q85
- q86.sf100
- q86
- q87.sf100
- q87
- q88.sf100
- q88
- q89.sf100
- q89
- q8
- q90.sf100
- q90
- q91.sf100
- q91
- q92.sf100
- q92
- q93.sf100
- q93
- q94.sf100
- q94
- q95.sf100
- q95
- q96.sf100
- q96
- q97.sf100
- q97
- q98.sf100
- q98
- q99.sf100
- q99
- approved-plans-v2_7
- q10a.sf100
- q10a
- q11.sf100
- q11
- q12.sf100
- q12
- q14.sf100
- q14a.sf100
- q14a
- q14
- q18a.sf100
- q18a
- q20.sf100
- q20
- q22.sf100
- q22a.sf100
- q22a
- q22
- q24.sf100
- q24
- q27a.sf100
- q27a
- q34.sf100
- q34
- q35.sf100
- q35a.sf100
- q35a
- q35
- q36a.sf100
- q36a
- q47.sf100
- q47
- q49.sf100
- q49
- q51a.sf100
- q51a
- q57.sf100
- q57
- q5a.sf100
- q5a
- q6.sf100
- q64.sf100
- q64
- q67a.sf100
- q67a
- q6
- q70a.sf100
- q70a
- q72.sf100
- q72
- q74.sf100
- q74
- q75.sf100
- q75
- q77a.sf100
- q77a
- q78.sf100
- q78
- q80a.sf100
- q80a
- q86a.sf100
- q86a
- q98.sf100
- q98
- tpch-plan-stability
- q1.sf100
- q10.sf100
- q10
- q11.sf100
- q11
- q12.sf100
- q12
- q13.sf100
- q13
- q14.sf100
- q14
- q15.sf100
- q15
- q16.sf100
- q16
- q17.sf100
- q17
- q18.sf100
- q18
- q19.sf100
- q19
- q1
- q2.sf100
- q20.sf100
- q20
- q21.sf100
- q21
- q22.sf100
- q22
- q2
- q3.sf100
- q3
- q4.sf100
- q4
- q5.sf100
- q5
- q6.sf100
- q6
- q7.sf100
- q7
- q8.sf100
- q8
- q9.sf100
- q9
- scala/org/apache/spark/sql
- connector
- execution
- adaptive
- arrow
- benchmark
- command
- v1
- v2
- datasources
- csv
- jdbc/connection
- json
- orc
- parquet
- v2
- jdbc
- debug
- exchange
- joins
- metric
- streaming
- sources
- state
- ui
- vectorized
- expressions
- internal
- jdbc
- sources
- streaming
- sources
- test
- util
- test
- hive-thriftserver
- src
- main
- java/org/apache/hive/service
- auth
- cli
- operation
- session
- thrift
- server
- scala/org/apache/spark/sql/hive/thriftserver
- ui
- test/scala/org/apache/spark/sql/hive/thriftserver
- ui
- hive
- src
- main/scala/org/apache/spark/sql/hive
- client
- execution
- orc
- security
- test/scala/org/apache/spark/sql
- hive
- client
- execution
- orc
- sources
- streaming
- src/test
- java
- org/apache/spark/streaming
- test/org/apache/spark/streaming
- scala/org/apache/spark/streaming
- tools
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
2,080 files changed
+114175
-56820
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
27 | 27 | | |
28 | 28 | | |
29 | 29 | | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
8 | 8 | | |
9 | 9 | | |
10 | 10 | | |
11 | | - | |
12 | | - | |
| 11 | + | |
| 12 | + | |
13 | 13 | | |
14 | 14 | | |
15 | 15 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
1 | 20 | | |
2 | 21 | | |
3 | 22 | | |
| |||
48 | 67 | | |
49 | 68 | | |
50 | 69 | | |
| 70 | + | |
| 71 | + | |
51 | 72 | | |
52 | 73 | | |
53 | 74 | | |
| |||
0 commit comments