File tree
1,515 files changed
+74369
-25607
lines changed- R/pkg
- R
- inst/worker
- tests/fulltests
- vignettes
- assembly
- bin
- build
- common
- network-common/src
- main/java/org/apache/spark/network
- client
- crypto
- protocol
- sasl
- server
- util
- test/java/org/apache/spark/network
- network-shuffle/src
- main/java/org/apache/spark/network/shuffle
- test/java/org/apache/spark/network/shuffle
- sketch/src/main/java/org/apache/spark/util/sketch
- unsafe/src
- main/java/org/apache/spark
- sql/catalyst/expressions
- unsafe
- array
- hash
- memory
- types
- test
- java/org/apache/spark/unsafe
- array
- hash
- memory
- types
- scala/org/apache/spark/unsafe/types
- core
- src
- main
- java/org/apache/spark
- io
- memory
- shuffle/sort
- unsafe/map
- util/collection/unsafe/sort
- resources/org/apache/spark/ui/static
- scala/org/apache/spark
- api
- python
- r
- deploy
- history
- master/ui
- rest
- security
- worker
- ui
- executor
- internal
- config
- io
- launcher
- mapred
- rdd
- scheduler
- cluster
- security
- serializer
- shuffle
- sort
- status
- api/v1
- storage
- ui
- env
- exec
- jobs
- storage
- util
- collection
- io
- test
- java/org/apache/spark
- io
- launcher
- memory
- shuffle/sort
- util/collection/unsafe/sort
- resources/HistoryServerExpectations
- scala/org/apache/spark
- deploy
- history
- rest
- worker
- executor
- internal/io
- io
- network/netty
- rdd
- scheduler
- security
- shuffle
- sort
- status
- storage
- ui
- storage
- util
- collection
- unsafe/sort
- dev
- create-release
- spark-rm
- deps
- sparktestsupport
- tests
- docs
- _plugins
- css
- examples/src/main
- java/org/apache/spark/examples/ml
- python
- mllib
- ml
- sql
- streaming
- streaming
- scala/org/apache/spark/examples
- ml
- streaming
- external
- kafka-0-10-sql/src
- main/scala/org/apache/spark/sql/kafka010
- test
- resources
- scala/org/apache/spark/sql/kafka010
- kafka-0-10/src
- main/scala/org/apache/spark/streaming/kafka010
- test/scala/org/apache/spark/streaming/kafka010
- mocks
- kafka-0-8/src
- main/scala/org/apache/spark/streaming/kafka
- test/scala/org/apache/spark/streaming/kafka
- kinesis-asl/src/main/python/examples/streaming
- hadoop-cloud
- launcher/src
- main/java/org/apache/spark/launcher
- test/java/org/apache/spark/launcher
- licenses
- mllib/src
- main
- resources/META-INF/services
- scala/org/apache/spark
- mllib
- api/python
- clustering
- feature
- fpm
- ml
- classification
- clustering
- evaluation
- feature
- fpm
- optim
- param
- recommendation
- regression
- stat
- tree
- impl
- tuning
- util
- test
- java/org/apache/spark
- ml/stat
- resources/META-INF/services
- scala/org/apache/spark
- mllib/tree
- ml
- classification
- clustering
- evaluation
- feature
- fpm
- image
- recommendation
- regression
- stat
- tree/impl
- tuning
- util
- project
- python
- docs
- lib
- pyspark
- mllib
- linalg
- stat
- ml
- linalg
- param
- sql
- streaming
- test_support/sql
- repl
- scala-2.11/src/main/scala/org/apache/spark/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
- bindings
- submit
- steps
- initcontainer
- scheduler/cluster/k8s
- test/scala/org/apache/spark
- deploy/k8s
- features
- bindings
- submit
- steps
- initcontainer
- scheduler/cluster/k8s
- docker/src/main/dockerfiles/spark
- bindings/python
- integration-tests
- dev
- scripts
- src/test
- resources
- scala/org/apache/spark/deploy/k8s/integrationtest
- backend
- minikube
- mesos/src
- main/scala/org/apache/spark
- deploy/mesos
- ui
- scheduler/cluster/mesos
- test/scala/org/apache/spark/scheduler/cluster/mesos
- yarn/src
- main/scala/org/apache/spark
- deploy/yarn
- security
- scheduler/cluster
- test/scala/org/apache/spark/deploy/yarn
- security
- sbin
- sql
- catalyst/src
- main
- antlr4/org/apache/spark/sql/catalyst/parser
- java/org/apache/spark/sql/catalyst/expressions
- codegen
- xml
- scala/org/apache/spark/sql
- catalyst
- analysis
- catalog
- dsl
- encoders
- expressions
- aggregate
- codegen
- objects
- xml
- json
- optimizer
- parser
- planning
- plans
- logical
- statsEstimation
- physical
- trees
- util
- internal
- types
- test
- java/org/apache/spark/sql/catalyst/expressions
- scala/org/apache/spark/sql
- catalyst
- analysis
- catalog
- expressions
- codegen
- xml
- optimizer
- parser
- plans
- statsEstimation
- trees
- util
- types
- core
- src
- main
- java/org/apache/spark/sql
- execution
- datasources
- orc
- parquet
- vectorized
- sources/v2
- reader
- partitioning
- streaming
- writer
- streaming
- vectorized
- resources/META-INF/services
- scala/org/apache/spark/sql
- execution
- aggregate
- arrow
- columnar
- compression
- command
- datasources
- csv
- jdbc
- json
- orc
- parquet
- text
- v2
- exchange
- joins
- metric
- python
- streaming
- continuous
- shuffle
- sources
- state
- ui
- window
- expressions
- internal
- streaming
- test
- java/test/org/apache/spark/sql
- execution/sort
- sources/v2
- resources
- sql-tests
- inputs
- subquery/in-subquery
- typeCoercion/native
- results
- subquery/in-subquery
- typeCoercion/native
- test-data
- tpcds-v2.7.0
- scala/org/apache/spark/sql
- execution
- benchmark
- columnar
- compression
- command
- datasources
- csv
- json
- orc
- parquet
- text
- debug
- joins
- metric
- python
- streaming
- sources
- state
- ui
- vectorized
- internal
- jdbc
- sources
- v2
- streaming
- continuous
- shuffle
- sources
- test
- hive-thriftserver/src
- main
- java/org/apache/hive/service
- auth
- cli/session
- scala/org/apache/spark/sql/hive/thriftserver
- server
- ui
- test/scala/org/apache/spark/sql/hive
- thriftserver
- hive/src
- main/scala/org/apache/spark/sql/hive
- client
- execution
- orc
- test
- test/scala/org/apache/spark/sql
- catalyst
- hive
- client
- execution
- orc
- test
- sources
- streaming/src
- main/scala/org/apache/spark/streaming
- receiver
- scheduler
- ui
- util
- 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.
1,515 files changed
+74369
-25607
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
76 | 76 | | |
77 | 77 | | |
78 | 78 | | |
| 79 | + | |
79 | 80 | | |
80 | 81 | | |
81 | 82 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
237 | 237 | | |
238 | 238 | | |
239 | 239 | | |
| 240 | + | |
240 | 241 | | |
241 | 242 | | |
242 | 243 | | |
243 | 244 | | |
244 | 245 | | |
245 | | - | |
| 246 | + | |
246 | 247 | | |
247 | 248 | | |
248 | 249 | | |
249 | 250 | | |
250 | 251 | | |
251 | 252 | | |
252 | | - | |
253 | | - | |
254 | | - | |
255 | | - | |
256 | | - | |
| 253 | + | |
| 254 | + | |
| 255 | + | |
| 256 | + | |
| 257 | + | |
257 | 258 | | |
258 | 259 | | |
259 | 260 | | |
| |||
263 | 264 | | |
264 | 265 | | |
265 | 266 | | |
266 | | - | |
| 267 | + | |
267 | 268 | | |
268 | 269 | | |
269 | 270 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
13 | 13 | | |
14 | 14 | | |
15 | 15 | | |
| 16 | + | |
16 | 17 | | |
17 | 18 | | |
18 | 19 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
151 | 151 | | |
152 | 152 | | |
153 | 153 | | |
| 154 | + | |
154 | 155 | | |
155 | 156 | | |
156 | 157 | | |
| |||
200 | 201 | | |
201 | 202 | | |
202 | 203 | | |
| 204 | + | |
| 205 | + | |
| 206 | + | |
| 207 | + | |
| 208 | + | |
| 209 | + | |
| 210 | + | |
203 | 211 | | |
204 | 212 | | |
205 | 213 | | |
| |||
244 | 252 | | |
245 | 253 | | |
246 | 254 | | |
| 255 | + | |
247 | 256 | | |
248 | 257 | | |
249 | 258 | | |
| |||
253 | 262 | | |
254 | 263 | | |
255 | 264 | | |
| 265 | + | |
256 | 266 | | |
257 | 267 | | |
258 | 268 | | |
| |||
295 | 305 | | |
296 | 306 | | |
297 | 307 | | |
| 308 | + | |
298 | 309 | | |
299 | 310 | | |
300 | 311 | | |
| |||
345 | 356 | | |
346 | 357 | | |
347 | 358 | | |
| 359 | + | |
348 | 360 | | |
349 | 361 | | |
350 | 362 | | |
| |||
0 commit comments