Commit 45cdced
committed
File tree
2,828 files changed
+159565
-45557
lines changed- .github
- workflows
- .mvn
- R
- binder
- build
- common
- kvstore/src/main/java/org/apache/spark/util/kvstore
- network-common
- src/test/java/org/apache/spark/network
- ssl
- network-shuffle
- network-yarn
- unsafe/src/main/java/org/apache/spark/sql/catalyst/util
- utils-java/src
- main
- java/org/apache/spark
- internal
- network/util
- util
- resources/org/apache/spark
- test/java/org/apache/spark/util
- utils/src/main
- java/org/apache/spark
- resources/error
- scala/org/apache/spark
- internal/config
- sql/streaming
- util
- conf
- connector
- avro
- benchmarks
- src/test/scala/org/apache/spark/sql/avro
- docker-integration-tests
- src/test
- resources
- scala/org/apache/spark/sql/jdbc
- querytest
- v2
- join
- kafka-0-10-sql
- src
- main/scala/org/apache/spark/sql/kafka010
- test/scala/org/apache/spark/sql/kafka010
- kinesis-asl
- src
- main
- java/org/apache/spark
- examples/streaming
- streaming/kinesis
- scala/org/apache/spark
- examples/streaming
- streaming/kinesis
- test
- java/org/apache/spark/streaming/kinesis
- scala/org/apache/spark/streaming/kinesis
- protobuf/src
- main/scala/org/apache/spark/sql/protobuf
- utils
- test
- resources/protobuf
- scala/org/apache/spark/sql/protobuf
- core
- benchmarks
- src
- main
- java/org/apache/spark
- memory
- util
- protobuf/org/apache/spark/status/protobuf
- resources/org/apache/spark/ui/static
- scala/org/apache/spark
- api/python
- deploy
- history
- master/ui
- rest
- security
- worker/ui
- executor
- input
- internal/config
- io
- memory
- metrics
- sink
- rdd
- resource
- scheduler
- serializer
- status
- api/v1
- storage
- ui
- env
- exec
- jobs
- scope
- storage
- util
- test
- java/org/apache/spark/unsafe
- resources
- HistoryServerExpectations
- spark-events/eventlog_v2_local-1766844910796
- scala/org/apache/spark
- deploy
- client
- history
- executor
- io
- network/netty
- scheduler
- shuffle/sort
- storage
- ui
- env
- storage
- unsafe
- util
- dev
- create-release
- spark-rm
- deps
- infra
- spark-test-image
- connect-gen-protos
- docs
- lint
- pypy-310
- pypy-311
- python-310
- python-311
- python-312-classic-only
- python-312-pandas-3
- python-312
- python-313
- python-314-nogil
- python-314
- python-minimum
- python-ps-minimum
- sparkr
- sparktestsupport
- docs
- _includes
- _layouts
- control-flow
- img
- streaming
- examples/src/main
- python
- ml
- sql
- scala/org/apache/spark/examples/sql
- launcher/src/main/java/org/apache/spark/launcher
- licenses-binary
- licenses
- mllib-local/benchmarks
- mllib
- benchmarks
- src
- main/scala/org/apache/spark
- mllib/clustering
- ml
- clustering
- feature
- sql/ml
- test/scala/org/apache/spark/ml
- clustering
- feature
- project
- python
- benchmarks
- docs/source
- development
- getting_started
- migration_guide
- reference/pyspark.sql
- tutorial/sql
- packaging
- classic
- client
- connect
- pyspark
- core
- errors
- exceptions
- tests
- connect
- logger
- tests
- connect
- mllib
- linalg
- stat
- tests
- ml
- connect
- deepspeed/tests
- linalg
- tests
- connect
- tuning
- torch
- tests
- pandas
- data_type_ops
- indexes
- plot
- tests
- computation
- connect
- computation
- data_type_ops
- diff_frames_ops
- frame
- groupby
- indexes
- io
- plot
- resample
- reshape
- series
- window
- data_type_ops
- diff_frames_ops
- frame
- groupby
- indexes
- io
- plot
- resample
- reshape
- series
- window
- typedef
- usage_logging
- pipelines/tests
- resource/tests
- sql
- classic
- connect
- avro
- client
- functions
- protobuf
- proto
- streaming
- worker
- functions
- pandas
- _typing
- plot
- streaming
- proto
- tests
- arrow
- coercion
- connect
- arrow
- client
- pandas
- streaming
- shell
- streaming
- pandas
- helper
- streaming
- plot
- streaming
- typing
- udf_type_tests
- worker
- streaming/tests
- testing
- tests
- tests
- upstream
- pyarrow
- test_coverage
- test_support
- 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
- volcano/src
- main/scala/org/apache/spark/deploy/k8s/features
- test/scala/org/apache/spark/deploy/k8s/features
- docker/src/main/dockerfiles/spark
- bindings/python
- integration-tests
- scripts
- src/test/scala/org/apache/spark/deploy/k8s/integrationtest
- backend
- docker
- minikube
- volcano/src/test/scala/org/apache/spark/deploy/k8s/integrationtest
- yarn
- src
- main/scala/org/apache/spark/deploy/yarn/config
- test/scala/org/apache/spark/deploy/yarn
- sql
- api/src
- main
- antlr4/org/apache/spark/sql/catalyst/parser
- java/org/apache/spark/sql
- internal/types
- types
- scala/org/apache/spark/sql
- catalog
- catalyst
- encoders
- parser
- util
- errors
- internal
- streaming
- types
- ops
- util
- test
- java/org/apache/spark/sql/types
- scala/org/apache/spark/sql
- catalyst
- benchmarks
- src
- main
- java/org/apache/spark/sql
- catalyst
- expressions
- util
- geo
- connector
- catalog
- constraints
- functions
- procedures
- read
- streaming
- vectorized
- scala/org/apache/spark/sql
- catalyst
- analysis
- resolver
- catalog
- csv
- encoders
- expressions
- aggregate
- codegen
- st
- variant
- normalizer
- optimizer
- parser
- plans
- logical
- physical
- rules
- streaming
- trees
- types
- ops
- util
- xml
- connector/catalog
- errors
- exceptions
- execution
- arrow
- datasources/v2
- internal
- connector
- metricview
- logical
- serde
- util
- util
- test
- java/org/apache/spark/sql/catalyst
- util/geo
- scala/org/apache/spark/sql
- catalyst
- analysis
- catalog
- encoders
- expressions
- aggregate
- codegen
- optimizer
- parser
- plans
- util
- connector/catalog
- execution/datasources/v2
- metricview/serde
- types
- util
- connect
- bin
- client
- jdbc/src
- main/scala/org/apache/spark/sql/connect/client/jdbc
- test/scala/org/apache/spark/sql/connect/client/jdbc
- jvm/src/test/scala/org/apache/spark/sql
- application
- connect
- client
- arrow
- streaming
- test
- common
- src
- main
- protobuf/spark/connect
- scala/org/apache/spark/sql/connect
- client
- arrow
- common
- test/resources/query-tests
- explain-results
- queries
- docs
- server/src
- main
- java/org/apache/spark/sql/connect/plugin
- scala/org/apache/spark/sql/connect
- config
- execution
- ml
- pipelines
- planner
- plugin
- service
- ui
- utils
- test/scala/org/apache/spark/sql/connect
- ml
- pipelines
- planner
- plugin
- service
- ui
- core
- benchmarks
- src
- main
- java/org/apache/spark/sql/execution
- datasources/parquet
- vectorized
- resources/org/apache/spark/sql/execution/ui/static
- scala/org/apache/spark
- sql
- artifact
- avro
- catalyst/analysis
- classic
- execution
- adaptive
- arrow
- columnar
- command
- v2
- datasources
- csv
- jdbc
- connection
- json
- orc
- parquet
- v2
- csv
- jdbc
- json
- orc
- parquet
- python
- state
- metadata
- utils
- xml
- exchange
- joins
- python
- streaming
- streaming
- checkpointing
- continuous
- operators/stateful
- join
- transformwithstate
- testing
- timers
- runtime
- sources
- state
- utils
- ui
- window
- internal
- jdbc
- scripting
- sources
- streaming
- ui
- status
- api/v1/sql
- protobuf/sql
- test
- java
- org/apache/spark/sql/internal/types
- test/org/apache/spark/sql
- resources
- sql-functions
- sql-tests
- analyzer-results
- nonansi
- postgreSQL
- subquery/scalar-subquery
- udf
- inputs
- nonansi
- subquery/in-subquery
- results
- nonansi
- postgreSQL
- subquery/in-subquery
- scala/org/apache/spark
- sql
- analysis/resolver
- artifact
- collation
- connector
- catalog/functions
- functions
- errors
- execution
- adaptive
- arrow
- bucketing
- command
- v1
- v2
- datasources
- jdbc/connection
- orc
- parquet
- v2
- jdbc
- state
- xml
- parsers
- exchange
- history
- joins
- metric
- python
- streaming
- streaming
- state
- ui
- vectorized
- expressions
- internal
- jdbc
- scripting
- sources
- streaming
- continuous
- test
- util
- test
- status
- api/v1/sql
- protobuf/sql
- hive-thriftserver
- src
- main
- java/org/apache/hive/service
- auth
- cli/thrift
- scala/org/apache/spark/sql/hive/thriftserver
- ui
- test/scala/org/apache/spark/sql/hive/thriftserver
- ui
- hive
- benchmarks
- src
- main/scala/org/apache/spark/sql/hive
- client
- execution
- test
- resources
- conf/binding-policy-exceptions
- data/scripts
- scala/org/apache/spark/sql
- configaudit
- hive
- client
- execution
- command
- test
- pipelines/src
- main/scala/org/apache/spark/sql/pipelines/graph
- test/scala/org/apache/spark/sql/pipelines
- graph
- logging
- utils
- streaming
- src/main/scala/org/apache/spark/streaming
- ui
- util
- ui-test
- tests
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
2,828 files changed
+159565
-45557
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
18 | 18 | | |
19 | 19 | | |
20 | 20 | | |
| 21 | + | |
| 22 | + | |
21 | 23 | | |
22 | 24 | | |
23 | 25 | | |
| |||
This file was deleted.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
28 | 28 | | |
29 | 29 | | |
30 | 30 | | |
31 | | - | |
| 31 | + | |
32 | 32 | | |
33 | 33 | | |
34 | 34 | | |
35 | 35 | | |
36 | 36 | | |
| 37 | + | |
37 | 38 | | |
38 | 39 | | |
39 | 40 | | |
| |||
72 | 73 | | |
73 | 74 | | |
74 | 75 | | |
75 | | - | |
| 76 | + | |
76 | 77 | | |
77 | 78 | | |
78 | 79 | | |
79 | 80 | | |
80 | 81 | | |
81 | | - | |
| 82 | + | |
82 | 83 | | |
83 | 84 | | |
84 | 85 | | |
85 | 86 | | |
86 | | - | |
| 87 | + | |
87 | 88 | | |
88 | 89 | | |
89 | 90 | | |
| |||
93 | 94 | | |
94 | 95 | | |
95 | 96 | | |
96 | | - | |
| 97 | + | |
97 | 98 | | |
98 | 99 | | |
99 | 100 | | |
100 | 101 | | |
101 | 102 | | |
102 | 103 | | |
103 | 104 | | |
104 | | - | |
| 105 | + | |
105 | 106 | | |
106 | 107 | | |
107 | 108 | | |
108 | 109 | | |
109 | 110 | | |
110 | 111 | | |
111 | 112 | | |
112 | | - | |
| 113 | + | |
113 | 114 | | |
114 | 115 | | |
115 | 116 | | |
| |||
119 | 120 | | |
120 | 121 | | |
121 | 122 | | |
122 | | - | |
| 123 | + | |
123 | 124 | | |
124 | 125 | | |
125 | 126 | | |
| |||
136 | 137 | | |
137 | 138 | | |
138 | 139 | | |
| 140 | + | |
139 | 141 | | |
140 | 142 | | |
141 | 143 | | |
| |||
150 | 152 | | |
151 | 153 | | |
152 | 154 | | |
153 | | - | |
| 155 | + | |
154 | 156 | | |
155 | 157 | | |
156 | 158 | | |
157 | 159 | | |
158 | | - | |
| 160 | + | |
159 | 161 | | |
160 | 162 | | |
161 | 163 | | |
| |||
165 | 167 | | |
166 | 168 | | |
167 | 169 | | |
168 | | - | |
| 170 | + | |
169 | 171 | | |
170 | 172 | | |
171 | 173 | | |
172 | 174 | | |
173 | 175 | | |
174 | 176 | | |
175 | | - | |
| 177 | + | |
176 | 178 | | |
177 | 179 | | |
178 | 180 | | |
179 | 181 | | |
180 | | - | |
| 182 | + | |
181 | 183 | | |
182 | | - | |
| 184 | + | |
183 | 185 | | |
184 | 186 | | |
185 | 187 | | |
| |||
223 | 225 | | |
224 | 226 | | |
225 | 227 | | |
226 | | - | |
| 228 | + | |
227 | 229 | | |
228 | 230 | | |
229 | 231 | | |
| |||
0 commit comments