Commit 0d40311
committed
Merge remote-tracking branch 'upstream/master' into SPARK-32940
File tree
700 files changed
+13086
-6886
lines changed- .github/workflows
- R/pkg
- R
- tests/fulltests
- common
- network-yarn/src/main/java/org/apache/spark/network/yarn
- unsafe/src
- main/java/org/apache/spark/unsafe/types
- test/java/org/apache/spark/unsafe/array
- core
- src
- main
- java/org/apache/spark
- memory
- resources
- error
- org/apache/spark/ui/static
- scala/org/apache/spark
- api/python
- broadcast
- deploy
- scheduler
- shuffle
- sort
- status
- api/v1
- storage
- ui/jobs
- util
- test
- java/org/apache/spark/memory
- resources
- HistoryServerExpectations
- spark-events
- scala/org/apache/spark
- deploy/history
- input
- scheduler
- shuffle
- status
- storage
- ui
- util
- io
- dev
- deps
- docs
- external/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/v2
- mllib/src
- main/scala/org/apache/spark/ml
- feature
- image
- test/scala/org/apache/spark/ml/feature
- project
- python
- docs/source
- development
- getting_started
- migration_guide
- reference
- pyspark.pandas
- user_guide/pandas_on_spark
- pyspark
- mllib
- ml
- pandas
- data_type_ops
- indexes
- missing
- plot
- spark
- tests
- indexes
- typedef
- sql
- avro
- pandas
- tests
- resource-managers
- kubernetes/core/src
- main/scala/org/apache/spark/deploy/k8s
- features
- test/scala/org/apache/spark/deploy/k8s
- yarn/src/main/scala/org/apache/spark
- deploy/yarn
- scheduler/cluster
- sql
- catalyst/src
- main
- antlr4/org/apache/spark/sql/catalyst/parser
- java/org/apache/spark/sql
- catalyst/expressions
- connector/catalog/index
- scala/org/apache/spark/sql
- catalyst
- analysis
- catalog
- dsl
- expressions
- aggregate
- optimizer
- parser
- plans/logical
- util
- connector/catalog
- errors
- internal
- types
- test/scala/org/apache/spark/sql
- catalyst
- analysis
- expressions
- optimizer
- parser
- util
- types
- core
- src
- main
- java/org/apache/spark/sql/execution/datasources/parquet
- scala/org/apache/spark/sql
- catalyst/analysis
- execution
- aggregate
- command
- datasources
- jdbc
- json
- orc
- parquet
- v2
- jdbc
- json
- orc
- parquet
- dynamicpruning
- exchange
- joins
- python
- jdbc
- test
- java/test/org/apache/parquet/column/page
- resources
- sql-functions
- sql-tests
- inputs
- results
- ansi
- postgreSQL
- subquery/negative-cases
- timestampNTZ
- typeCoercion/native
- udf
- postgreSQL
- 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
- q10
- q11
- q12
- q13
- q14
- q15
- q16
- q17
- q18
- q19
- q20
- q21
- q22
- q2
- q3
- q4
- q5
- q7
- q8
- q9
- scala/org/apache/spark/sql
- connector
- execution
- command
- v1
- v2
- datasources
- csv
- json
- orc
- parquet
- debug
- sources
- test
- hive/src
- main/scala/org/apache/spark/sql/hive
- client
- execution
- test/scala/org/apache/spark/sql/hive
- client
- execution
- command
- streaming/src/test/scala/org/apache/spark/streaming
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
700 files changed
+13086
-6886
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
25 | 25 | | |
26 | 26 | | |
27 | 27 | | |
| 28 | + | |
| 29 | + | |
28 | 30 | | |
29 | 31 | | |
30 | 32 | | |
| |||
89 | 91 | | |
90 | 92 | | |
91 | 93 | | |
92 | | - | |
| 94 | + | |
93 | 95 | | |
94 | 96 | | |
95 | 97 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
29 | 29 | | |
30 | 30 | | |
31 | 31 | | |
32 | | - | |
| 32 | + | |
33 | 33 | | |
34 | 34 | | |
35 | 35 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
44 | 44 | | |
45 | 45 | | |
46 | 46 | | |
47 | | - | |
| 47 | + | |
48 | 48 | | |
49 | 49 | | |
50 | 50 | | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
33 | 33 | | |
34 | 34 | | |
35 | 35 | | |
36 | | - | |
| 36 | + | |
37 | 37 | | |
38 | 38 | | |
39 | 39 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
36 | 36 | | |
37 | 37 | | |
38 | 38 | | |
39 | | - | |
| 39 | + | |
40 | 40 | | |
41 | 41 | | |
42 | 42 | | |
43 | | - | |
| 43 | + | |
44 | 44 | | |
45 | 45 | | |
46 | 46 | | |
47 | 47 | | |
48 | 48 | | |
49 | 49 | | |
50 | | - | |
| 50 | + | |
51 | 51 | | |
52 | 52 | | |
53 | 53 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
27 | 27 | | |
28 | 28 | | |
29 | 29 | | |
30 | | - | |
| 30 | + | |
31 | 31 | | |
32 | 32 | | |
33 | 33 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
29 | 29 | | |
30 | 30 | | |
31 | 31 | | |
32 | | - | |
| 32 | + | |
33 | 33 | | |
34 | 34 | | |
35 | 35 | | |
36 | 36 | | |
37 | 37 | | |
38 | 38 | | |
39 | | - | |
| 39 | + | |
40 | 40 | | |
41 | 41 | | |
42 | 42 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
29 | 29 | | |
30 | 30 | | |
31 | 31 | | |
32 | | - | |
| 32 | + | |
33 | 33 | | |
34 | 34 | | |
35 | 35 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
478 | 478 | | |
479 | 479 | | |
480 | 480 | | |
481 | | - | |
| 481 | + | |
482 | 482 | | |
483 | 483 | | |
484 | 484 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
352 | 352 | | |
353 | 353 | | |
354 | 354 | | |
| 355 | + | |
355 | 356 | | |
356 | 357 | | |
357 | 358 | | |
| 359 | + | |
358 | 360 | | |
359 | 361 | | |
360 | 362 | | |
| |||
0 commit comments