File tree
636 files changed
+22690
-5578
lines changed- R/pkg
- R
- inst/tests/testthat
- tests/fulltests
- vignettes
- bin
- build
- common/network-common/src
- main/java/org/apache/spark/network
- client
- crypto
- protocol
- sasl
- server
- test/java/org/apache/spark/network
- core
- src
- main/scala/org/apache/spark
- api/java
- deploy
- rest
- input
- internal
- config
- io
- rdd
- scheduler
- status
- api/v1
- storage
- ui
- jobs
- util
- collection
- io
- test
- java/org/apache/spark/memory
- scala/org/apache/spark
- deploy
- input
- io
- rdd
- scheduler
- storage
- dev
- create-release
- deps
- sparktestsupport
- docs
- examples/src/main
- java/org/apache/spark/examples
- ml
- streaming
- python/ml
- scala/org/apache/spark/examples/ml
- external
- avro
- src
- main
- resources/META-INF/services
- scala/org/apache/spark/sql/avro
- test
- resources
- test-random-partitioned
- 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/src/main/scala/org/apache/spark/streaming/kafka010
- kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis
- graphx
- src/main/scala/org/apache/spark/graphx/util
- licenses-binary
- licenses
- mllib/src
- main/scala/org/apache/spark
- mllib
- clustering
- recommendation
- ml
- classification
- clustering
- feature
- fpm
- image
- recommendation
- regression
- tree/impl
- tuning
- util
- test/scala/org/apache/spark
- mllib/recommendation
- ml
- classification
- clustering
- evaluation
- feature
- recommendation
- regression
- util
- project
- python
- docs
- pyspark
- mllib
- linalg
- stat
- ml
- linalg
- param
- sql
- repl
- scala-2.11/src/main/scala/org/apache/spark/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
- bindings
- submit
- scheduler/cluster/k8s
- docker/src/main/dockerfiles/spark
- integration-tests
- dev
- src/test/scala/org/apache/spark/deploy/k8s/integrationtest
- mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos
- yarn/src
- main/scala/org/apache/spark
- deploy/yarn
- scheduler/cluster
- test/scala/org/apache/spark/deploy/yarn
- sql
- catalyst/src
- main
- antlr4/org/apache/spark/sql/catalyst/parser
- java/org/apache/spark/sql/catalyst/expressions
- scala/org/apache/spark/sql
- catalyst
- analysis
- catalog
- dsl
- expressions
- aggregate
- codegen
- objects
- json
- optimizer
- parser
- plans
- logical
- util
- internal
- types
- test/scala/org/apache/spark/sql
- catalyst
- analysis
- catalog
- expressions
- codegen
- optimizer
- parser
- util
- types
- core
- benchmarks
- src
- main
- java/org/apache/spark/sql
- execution
- datasources/parquet
- sources/v2
- reader
- writer
- scala/org/apache/spark/sql
- execution
- aggregate
- arrow
- columnar
- datasources
- csv
- jdbc
- json
- orc
- parquet
- text
- v2
- exchange
- metric
- stat
- streaming
- continuous
- shuffle
- sources
- state
- ui
- jdbc
- sources
- streaming
- test
- java/test/org/apache/spark/sql
- execution/sort
- sources/v2
- resources
- sql-tests
- inputs
- subquery
- exists-subquery
- in-subquery
- negative-cases
- typeCoercion/native
- results
- subquery/negative-cases
- typeCoercion/native
- structured-streaming
- checkpoint-version-2.3.1-flatMapGroupsWithState-state-format-1
- commits
- offsets
- state/0
- 0
- 1
- 2
- 3
- 4
- checkpoint-version-2.3.1-for-multi-watermark-policy
- commits
- offsets
- checkpoint-version-2.3.1-without-commit-log-metadata
- commits
- offsets
- state/0
- 0
- 1
- 2
- 3
- 4
- scala/org/apache/spark/sql
- execution
- benchmark
- command
- datasources
- csv
- json
- parquet
- text
- metric
- streaming
- sources
- state
- internal
- jdbc
- sources/v2
- streaming
- continuous
- shuffle
- sources
- test
- hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/ui
- hive/src
- main/scala/org/apache/spark/sql/hive
- client
- execution
- orc
- test/scala/org/apache/spark/sql/hive
- client
- execution
- orc
- streaming/src/main/scala/org/apache/spark/streaming/ui
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
636 files changed
+22690
-5578
lines changedLines changed: 58 additions & 100 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
201 | 201 |
| |
202 | 202 |
| |
203 | 203 |
| |
204 |
| - | |
205 |
| - | |
206 |
| - | |
207 |
| - | |
208 |
| - | |
209 |
| - | |
210 |
| - | |
211 |
| - | |
212 |
| - | |
213 |
| - | |
214 |
| - | |
215 |
| - | |
216 |
| - | |
217 |
| - | |
218 |
| - | |
219 |
| - | |
220 |
| - | |
221 |
| - | |
222 |
| - | |
223 |
| - | |
224 |
| - | |
225 |
| - | |
226 |
| - | |
227 |
| - | |
228 |
| - | |
229 |
| - | |
230 |
| - | |
231 |
| - | |
232 |
| - | |
233 |
| - | |
234 |
| - | |
235 |
| - | |
236 |
| - | |
237 |
| - | |
238 |
| - | |
239 |
| - | |
240 |
| - | |
241 |
| - | |
242 |
| - | |
243 |
| - | |
244 |
| - | |
245 |
| - | |
246 |
| - | |
247 |
| - | |
248 |
| - | |
249 |
| - | |
250 |
| - | |
251 |
| - | |
252 |
| - | |
253 |
| - | |
254 |
| - | |
255 |
| - | |
256 |
| - | |
257 |
| - | |
258 |
| - | |
259 |
| - | |
260 |
| - | |
261 |
| - | |
262 |
| - | |
263 |
| - | |
264 |
| - | |
265 |
| - | |
266 |
| - | |
267 |
| - | |
268 |
| - | |
269 |
| - | |
270 |
| - | |
271 |
| - | |
272 |
| - | |
273 |
| - | |
274 |
| - | |
275 |
| - | |
276 |
| - | |
277 |
| - | |
278 |
| - | |
279 |
| - | |
280 |
| - | |
281 |
| - | |
282 |
| - | |
283 |
| - | |
284 |
| - | |
285 |
| - | |
286 |
| - | |
287 |
| - | |
288 |
| - | |
289 |
| - | |
290 |
| - | |
291 |
| - | |
292 |
| - | |
293 |
| - | |
294 |
| - | |
295 |
| - | |
296 |
| - | |
297 |
| - | |
298 |
| - | |
299 |
| - | |
300 |
| - | |
301 |
| - | |
302 |
| - | |
303 |
| - | |
| 204 | + | |
| 205 | + | |
| 206 | + | |
| 207 | + | |
| 208 | + | |
| 209 | + | |
| 210 | + | |
| 211 | + | |
| 212 | + | |
| 213 | + | |
| 214 | + | |
| 215 | + | |
| 216 | + | |
| 217 | + | |
| 218 | + | |
| 219 | + | |
| 220 | + | |
| 221 | + | |
| 222 | + | |
| 223 | + | |
| 224 | + | |
| 225 | + | |
| 226 | + | |
| 227 | + | |
| 228 | + | |
| 229 | + | |
| 230 | + | |
| 231 | + | |
| 232 | + | |
| 233 | + | |
| 234 | + | |
| 235 | + | |
| 236 | + | |
| 237 | + | |
| 238 | + | |
| 239 | + | |
| 240 | + | |
| 241 | + | |
| 242 | + | |
| 243 | + | |
| 244 | + | |
| 245 | + | |
| 246 | + | |
| 247 | + | |
| 248 | + | |
| 249 | + | |
| 250 | + | |
| 251 | + | |
| 252 | + | |
| 253 | + | |
| 254 | + | |
| 255 | + | |
| 256 | + | |
| 257 | + | |
| 258 | + | |
| 259 | + | |
| 260 | + | |
| 261 | + |
0 commit comments