File tree
3,814 files changed
+306367
-98517
lines changed- .github
- R
- pkg
- R
- inst
- profile
- tests/testthat
- worker
- tests
- fulltests
- vignettes
- assembly
- bin
- 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
- buffer
- client
- crypto
- protocol
- sasl
- server
- util
- test/java/org/apache/spark/network
- crypto
- protocol
- sasl
- server
- util
- network-shuffle
- src
- main/java/org/apache/spark/network/shuffle
- protocol
- test/java/org/apache/spark/network
- sasl
- shuffle
- network-yarn
- src/main/java/org/apache/spark/network/yarn
- sketch
- src/main/java/org/apache/spark/util/sketch
- tags
- src/main/java/org/apache/spark/annotation
- 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
- conf
- core
- benchmarks
- src
- main
- java/org/apache/spark
- api/java
- io
- memory
- shuffle/sort
- storage
- unsafe/map
- util
- collection
- unsafe/sort
- resources
- META-INF/services
- org/apache/spark
- ui/static
- images
- scala/org/apache/spark
- api
- java
- python
- r
- broadcast
- deploy
- history
- master
- ui
- rest
- security
- worker
- ui
- executor
- input
- internal
- config
- io
- io
- launcher
- mapred
- memory
- metrics
- sink
- source
- network
- netty
- rdd
- util
- resource
- rpc
- netty
- scheduler
- cluster
- dynalloc
- local
- security
- serializer
- shuffle
- sort
- status
- api/v1
- storage
- memory
- ui
- env
- exec
- jobs
- storage
- util
- collection
- io
- logging
- random
- test
- java
- org/apache/spark
- launcher
- memory
- shuffle/sort
- unsafe/map
- util/collection/unsafe/sort
- test/org/apache/spark
- resources
- HistoryServerExpectations
- META-INF/services
- ProcfsMetrics
- 22763
- 26109
- spark-events
- scala/org/apache
- sparktest
- spark
- api/python
- benchmark
- broadcast
- deploy
- client
- history
- master
- ui
- rest
- security
- worker
- executor
- input
- internal
- io
- launcher
- memory
- metrics
- source
- network
- netty
- rdd
- resource
- rpc
- netty
- scheduler
- dynalloc
- security
- serializer
- shuffle
- sort
- status
- storage
- ui
- storage
- util
- collection
- unsafe/sort
- logging
- random
- data/mllib/images
- origin
- kittens
- multi-channel
- partitioned
- cls=kittens
- date=2018-01
- date=2018-02
- cls=multichannel
- date=2018-01
- date=2018-02
- dev
- create-release
- spark-rm
- deps
- sparktestsupport
- docs
- _data
- _includes
- _layouts
- _plugins
- js
- vendor
- examples
- src/main
- java/org/apache/spark/examples
- mllib
- ml
- sql
- streaming
- python
- mllib
- ml
- sql
- streaming
- resources
- partitioned_users.orc
- favorite_color=__HIVE_DEFAULT_PARTITION__
- favorite_color=red
- r
- ml
- scala/org/apache/spark/examples
- graphx
- mllib
- ml
- sql
- hive
- streaming
- streaming
- scripts
- external
- avro
- benchmarks
- src
- main
- resources/META-INF/services
- scala/org/apache/spark/sql/avro
- test
- java/org/apache/spark/sql/avro
- resources
- test-random-partitioned
- scala/org/apache/spark/sql
- avro
- execution
- benchmark
- datasources
- docker-integration-tests
- src/test/scala/org/apache/spark/sql/jdbc
- docker
- spark-mesos
- spark-test/base
- flume-assembly
- flume-sink
- src
- main
- avro
- scala/org/apache/spark/streaming/flume/sink
- test
- resources
- scala/org/apache/spark/streaming/flume/sink
- flume
- src
- main
- java/org/apache/spark/examples
- scala/org/apache/spark
- examples
- streaming/flume
- test
- java/org/apache/spark/streaming
- flume
- resources
- scala/org/apache/spark/streaming
- flume
- kafka-0-10-assembly
- kafka-0-10-sql
- src
- main/scala/org/apache/spark/sql/kafka010
- test/scala/org/apache/spark/sql/kafka010
- kafka-0-10-token-provider
- src
- main
- resources/META-INF/services
- scala/org/apache/spark/kafka010
- test
- resources
- scala/org/apache/spark/kafka010
- kafka-0-10
- src
- main/scala/org/apache/spark/streaming/kafka010
- test/scala/org/apache/spark/streaming/kafka010
- mocks
- kafka-0-8-assembly
- kafka-0-8
- src
- main/scala/org/apache/spark/streaming/kafka
- test
- java/org/apache/spark/streaming/kafka
- resources
- scala/org/apache/spark/streaming/kafka
- kinesis-asl-assembly
- kinesis-asl
- src
- main
- java/org/apache/spark/examples/streaming
- resources
- scala/org/apache/spark/streaming/kinesis
- test
- resources
- scala/org/apache/spark/streaming/kinesis
- spark-ganglia-lgpl
- src/main/scala/org/apache/spark/metrics/sink
- graphx
- src
- main/scala/org/apache/spark/graphx
- impl
- lib
- util
- test
- resources
- scala/org/apache/spark/graphx
- lib
- util
- graph
- api
- cypher
- graph
- hadoop-cloud
- launcher
- src
- main/java/org/apache/spark/launcher
- test
- java/org/apache/spark/launcher
- resources
- licenses-binary
- licenses
- mllib-local
- src
- main/scala/org/apache/spark/ml
- linalg
- stat/distribution
- test/scala/org/apache/spark/ml
- linalg
- util
- mllib
- benchmarks
- src
- main
- resources/META-INF/services
- scala/org/apache/spark
- mllib
- api/python
- classification
- clustering
- evaluation
- binary
- feature
- fpm
- linalg
- distributed
- optimization
- pmml/export
- recommendation
- regression
- stat
- distribution
- test
- tree
- configuration
- impurity
- model
- util
- ml
- ann
- attribute
- classification
- clustering
- evaluation
- feature
- fpm
- image
- optim
- aggregator
- loss
- param
- recommendation
- regression
- r
- source
- image
- libsvm
- stat
- tree
- impl
- tuning
- util
- test
- java/org/apache/spark
- mllib/regression
- ml/feature
- resources
- test-data/strIndexerModel
- data
- metadata
- scala/org/apache/spark
- mllib
- classification
- clustering
- evaluation
- feature
- fpm
- linalg
- distributed
- optimization
- pmml/export
- recommendation
- regression
- stat/distribution
- tree
- util
- ml
- attribute
- classification
- clustering
- evaluation
- feature
- fpm
- image
- linalg
- recommendation
- regression
- source/image
- tree/impl
- tuning
- util
- project
- python
- docs
- _static
- lib
- pyspark
- mllib
- linalg
- stat
- tests
- ml
- linalg
- param
- tests
- sql
- avro
- tests
- streaming
- tests
- testing
- tests
- repl
- scala-2.11/src/main/scala/org/apache/spark/repl
- scala-2.12/src/main/scala/org/apache/spark/repl
- src
- main/scala/org/apache/spark/repl
- test
- resources
- scala/org/apache/spark/repl
- resource-managers
- kubernetes
- core
- src
- main
- resources/META-INF/services
- scala/org/apache/spark
- deploy/k8s
- features
- bindings
- submit
- scheduler/cluster/k8s
- test
- resources
- scala/org/apache/spark
- deploy/k8s
- features
- bindings
- submit
- scheduler/cluster/k8s
- docker/src/main/dockerfiles/spark
- bindings
- R
- python
- integration-tests
- dev
- scripts
- src/test
- resources
- scala/org/apache/spark/deploy/k8s/integrationtest
- backend
- cloud
- docker
- minikube
- tests
- mesos
- src
- main/scala/org/apache/spark
- deploy
- mesos
- ui
- rest/mesos
- executor
- scheduler/cluster/mesos
- test/scala/org/apache/spark
- deploy
- mesos
- rest/mesos
- scheduler/cluster/mesos
- yarn
- src
- main/scala/org/apache/spark
- deploy/yarn
- security
- executor
- scheduler/cluster
- util
- test
- java/org
- apache/hadoop/net
- eclipse/jetty/server
- session
- resources
- META-INF/services
- scala/org/apache/spark
- deploy/yarn
- security
- network/yarn
- scheduler/cluster
- sbin
- sql
- catalyst
- benchmarks
- src
- main
- antlr4/org/apache/spark/sql/catalyst/parser
- java/org/apache/spark/sql
- catalog/v2
- expressions
- utils
- catalyst/expressions
- codegen
- xml
- execution
- sources/v2
- reader
- partitioning
- streaming
- writer
- streaming
- streaming
- types
- util
- vectorized
- scala/org/apache/spark/sql
- catalog/v2
- expressions
- catalyst
- analysis
- catalog
- csv
- dsl
- encoders
- expressions
- aggregate
- codegen
- objects
- json
- optimizer
- parser
- planning
- plans
- logical
- sql
- statsEstimation
- physical
- rules
- trees
- util
- execution/datasources/v2
- internal
- sources
- types
- util
- test
- java/org/apache/spark/sql
- catalog/v2
- catalyst/expressions
- resources
- scala/org/apache/spark/sql
- catalog/v2
- expressions
- catalyst
- analysis
- catalog
- v2
- csv
- encoders
- expressions
- aggregate
- codegen
- xml
- json
- optimizer
- parser
- plans
- logical
- statsEstimation
- trees
- util
- types
- util
- core
- benchmarks
- src
- main
- java/org/apache/spark
- api/java/function
- sql
- api/java
- execution
- datasources
- orc
- parquet
- streaming
- vectorized
- expressions/javalang
- internal
- sources/v2
- reader
- streaming
- writer
- streaming
- streaming
- vectorized
- resources
- META-INF/services
- org/apache/spark/sql/execution/ui/static
- scala/org/apache/spark/sql
- api
- python
- r
- catalog
- execution
- adaptive
- aggregate
- arrow
- columnar
- command
- datasources
- binaryfile
- csv
- jdbc
- json
- noop
- orc
- parquet
- text
- v2
- csv
- json
- orc
- parquet
- text
- debug
- exchange
- joins
- metric
- python
- r
- stat
- streaming
- continuous
- shuffle
- sources
- state
- ui
- window
- expressions
- scalalang
- internal
- jdbc
- sources
- streaming
- test
- util
- test
- java/test/org/apache/spark/sql
- execution/sort
- sources/v2
- streaming
- resources
- META-INF/services
- sql-tests
- inputs
- ansi
- pgSQL
- subquery
- exists-subquery
- in-subquery
- negative-cases
- typeCoercion/native
- udf
- results
- ansi
- pgSQL
- subquery
- in-subquery
- negative-cases
- typeCoercion/native
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
3,814 files changed
+306367
-98517
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
7 | 7 | | |
8 | 8 | | |
9 | 9 | | |
10 | | - | |
| 10 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
94 | 94 | | |
95 | 95 | | |
96 | 96 | | |
| 97 | + | |
| 98 | + | |
| 99 | + | |
This file was deleted.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | 2 | | |
3 | 3 | | |
4 | | - | |
| 4 | + | |
5 | 5 | | |
6 | 6 | | |
7 | 7 | | |
8 | 8 | | |
9 | | - | |
| 9 | + | |
10 | 10 | | |
11 | 11 | | |
12 | 12 | | |
| |||
| 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