File tree
1,762 files changed
+70538
-54941
lines changed- R
- pkg
- R
- inst/profile
- 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
- crypto
- protocol
- sasl
- server
- util
- test/java/org/apache/spark/network
- crypto
- network-shuffle
- src
- main/java/org/apache/spark/network/shuffle
- test/java/org/apache/spark/network/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
- core
- benchmarks
- src
- main
- java/org/apache/spark
- api/java
- io
- memory
- shuffle/sort
- storage
- unsafe/map
- util/collection/unsafe/sort
- resources/org/apache/spark/ui/static
- images
- scala/org/apache/spark
- api
- java
- python
- r
- broadcast
- deploy
- history
- rest
- security
- worker
- executor
- input
- internal
- config
- io
- io
- memory
- metrics
- sink
- network
- netty
- rdd
- scheduler
- cluster
- security
- serializer
- shuffle
- sort
- status
- api/v1
- storage
- memory
- ui
- jobs
- storage
- util
- collection
- io
- logging
- random
- test
- java
- org/apache/spark
- memory
- shuffle/sort
- unsafe/map
- util/collection/unsafe/sort
- test/org/apache/spark
- resources
- HistoryServerExpectations
- spark-events
- scala/org/apache
- spark
- api/python
- benchmark
- deploy
- history
- master
- ui
- rest
- security
- executor
- input
- io
- rdd
- rpc
- scheduler
- security
- serializer
- shuffle
- sort
- status
- storage
- ui
- storage
- util
- collection
- unsafe/sort
- logging
- sparktest
- 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
- examples
- src/main
- java/org/apache/spark/examples
- ml
- sql
- python
- ml
- sql
- streaming
- r
- ml
- resources
- scala/org/apache/spark/examples
- ml
- sql
- external
- avro
- benchmarks
- src
- main/scala/org/apache/spark/sql/avro
- test/scala/org/apache/spark/sql
- avro
- execution/benchmark
- docker-integration-tests
- src/test/scala/org/apache/spark/sql/jdbc
- flume
- src
- main
- java/org/apache/spark/examples
- scala/org/apache/spark
- examples
- streaming/flume
- test
- java/org/apache/spark/streaming
- flume
- scala/org/apache/spark/streaming
- flume
- flume-assembly
- flume-sink
- src
- main
- avro
- scala/org/apache/spark/streaming/flume/sink
- test/scala/org/apache/spark/streaming/flume/sink
- kafka-0-10
- src
- main/scala/org/apache/spark/streaming/kafka010
- test/scala/org/apache/spark/streaming/kafka010
- 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-8
- src
- main/scala/org/apache/spark/streaming/kafka
- test
- java/org/apache/spark/streaming/kafka
- scala/org/apache/spark/streaming/kafka
- kafka-0-8-assembly
- kinesis-asl
- src
- main
- java/org/apache/spark/examples/streaming
- scala/org/apache/spark/streaming/kinesis
- test/scala/org/apache/spark/streaming/kinesis
- kinesis-asl-assembly
- spark-ganglia-lgpl
- src/main/scala/org/apache/spark/metrics/sink
- graphx
- src/main/scala/org/apache/spark/graphx
- impl
- lib
- util
- hadoop-cloud
- launcher
- src/main/java/org/apache/spark/launcher
- mllib
- benchmarks
- src
- main
- resources/META-INF/services
- scala/org/apache/spark
- ml
- classification
- clustering
- evaluation
- feature
- fpm
- image
- param
- r
- recommendation
- regression
- source/image
- stat
- tree
- impl
- tuning
- util
- mllib
- classification
- clustering
- evaluation
- feature
- fpm
- linalg
- distributed
- recommendation
- regression
- stat
- distribution
- test
- util
- test
- java/org/apache/spark/ml/feature
- scala/org/apache/spark
- ml
- attribute
- classification
- clustering
- feature
- fpm
- image
- linalg
- recommendation
- regression
- source/image
- tree/impl
- tuning
- util
- mllib
- classification
- clustering
- evaluation
- feature
- linalg
- distributed
- stat/distribution
- tree
- mllib-local
- src
- main/scala/org/apache/spark/ml
- linalg
- stat/distribution
- test/scala/org/apache/spark/ml/linalg
- project
- python
- docs
- lib
- pyspark
- ml
- tests
- mllib
- linalg
- tests
- sql
- tests
- streaming
- tests
- testing
- tests
- repl
- src
- main
- scala/org/apache/spark/repl
- scala-2.11/org/apache/spark/repl
- test/scala/org/apache/spark/repl
- resource-managers
- kubernetes
- core
- src
- main/scala/org/apache/spark
- deploy/k8s
- features
- bindings
- hadooputils
- submit
- scheduler/cluster/k8s
- test/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
- tests
- mesos
- src
- main/scala/org/apache/spark
- deploy/mesos
- 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
- network/yarn
- sbin
- sql
- catalyst
- benchmarks
- src
- main
- antlr4/org/apache/spark/sql/catalyst/parser
- java/org/apache/spark/sql
- catalyst/expressions
- codegen
- execution
- streaming
- types
- scala/org/apache/spark/sql
- catalyst
- analysis
- catalog
- csv
- dsl
- encoders
- expressions
- aggregate
- codegen
- objects
- json
- optimizer
- parser
- planning
- plans
- logical
- statsEstimation
- physical
- rules
- trees
- util
- internal
- types
- util
- test
- java/org/apache/spark/sql/catalyst/expressions
- scala/org/apache/spark/sql
- catalyst
- analysis
- catalog
- csv
- encoders
- expressions
- aggregate
- codegen
- optimizer
- parser
- plans
- statsEstimation
- trees
- util
- types
- util
- core
- benchmarks
- src
- main
- java/org/apache/spark
- api/java/function
- sql
- api/java
- execution
- datasources
- vectorized
- expressions/javalang
- sources/v2
- reader
- partitioning
- streaming
- writer
- streaming
- streaming
- vectorized
- scala/org/apache/spark/sql
- api
- python
- r
- catalog
- execution
- aggregate
- arrow
- columnar
- command
- datasources
- csv
- jdbc
- json
- orc
- parquet
- text
- v2
- debug
- exchange
- joins
- metric
- python
- stat
- streaming
- continuous
- sources
- state
- ui
- expressions
- scalalang
- internal
- jdbc
- sources
- streaming
- test
- util
- test
- java/test/org/apache/spark/sql
- sources/v2
- streaming
- resources
- sql-tests
- inputs
- subquery/in-subquery
- typeCoercion/native
- results
- subquery
- in-subquery
- negative-cases
- typeCoercion/native
- test-data
- scala/org/apache/spark/sql
- execution
- aggregate
- benchmark
- columnar
- compression
- command
- datasources
- csv
- json
- orc
- parquet
- text
- joins
- metric
- python
- streaming
- sources
- state
- ui
- vectorized
- internal
- jdbc
- sources
- v2
- streaming
- continuous
- sources
- test
- util
- hive
- benchmarks
- compatibility/src/test/scala/org/apache/spark/sql/hive/execution
- src
- main/scala/org/apache/spark/sql/hive
- client
- execution
- orc
- test
- test
- java/org/apache/spark/sql/hive/execution
- resources/regression-test-SPARK-8489
- scala/org/apache/spark/sql
- execution/benchmark
- hive
- client
- execution
- orc
- sources
- hive-thriftserver
- src
- gen/java/org/apache/hive/service/cli/thrift
- main
- java/org/apache/hive/service
- cli
- thrift
- server
- scala/org/apache/spark/sql/hive/thriftserver
- ui
- test/scala/org/apache/spark/sql/hive/thriftserver
- streaming
- src
- main/scala/org/apache/spark/streaming
- api/java
- dstream
- rdd
- scheduler
- ui
- util
- test
- java/test/org/apache/spark/streaming
- scala/org/apache/spark/streaming
- tools
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
1,762 files changed
+70538
-54941
lines changedLines changed: 0 additions & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
77 | 77 |
| |
78 | 78 |
| |
79 | 79 |
| |
80 |
| - | |
81 | 80 |
| |
82 | 81 |
| |
83 | 82 |
| |
|
Lines changed: 0 additions & 50 deletions
This file was deleted.
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
17 | 17 |
| |
18 | 18 |
| |
19 | 19 |
| |
20 |
| - | |
| 20 | + | |
21 | 21 |
| |
22 | 22 |
| |
23 | 23 |
| |
|
Lines changed: 2 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
3 | 3 |
| |
4 | 4 |
| |
5 | 5 |
| |
6 |
| - | |
| 6 | + | |
7 | 7 |
| |
8 | 8 |
| |
9 | 9 |
| |
| |||
14 | 14 |
| |
15 | 15 |
| |
16 | 16 |
| |
17 |
| - | |
| 17 | + | |
18 | 18 |
| |
19 | 19 |
| |
20 | 20 |
| |
|
Lines changed: 2 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 | 2 |
| |
3 |
| - | |
| 3 | + | |
4 | 4 |
| |
5 | 5 |
| |
6 | 6 |
| |
| |||
15 | 15 |
| |
16 | 16 |
| |
17 | 17 |
| |
18 |
| - | |
| 18 | + | |
19 | 19 |
| |
20 | 20 |
| |
21 | 21 |
| |
|
Lines changed: 14 additions & 12 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
28 | 28 |
| |
29 | 29 |
| |
30 | 30 |
| |
31 |
| - | |
32 |
| - | |
33 | 31 |
| |
| 32 | + | |
34 | 33 |
| |
35 | 34 |
| |
36 | 35 |
| |
| |||
42 | 41 |
| |
43 | 42 |
| |
44 | 43 |
| |
45 |
| - | |
46 |
| - | |
47 |
| - | |
48 | 44 |
| |
49 | 45 |
| |
50 | 46 |
| |
| |||
70 | 66 |
| |
71 | 67 |
| |
72 | 68 |
| |
73 |
| - | |
| 69 | + | |
| 70 | + | |
74 | 71 |
| |
75 | 72 |
| |
76 | 73 |
| |
| |||
150 | 147 |
| |
151 | 148 |
| |
152 | 149 |
| |
153 |
| - | |
154 | 150 |
| |
155 | 151 |
| |
156 | 152 |
| |
157 | 153 |
| |
158 | 154 |
| |
159 | 155 |
| |
160 | 156 |
| |
161 |
| - | |
162 | 157 |
| |
163 | 158 |
| |
164 | 159 |
| |
| |||
200 | 195 |
| |
201 | 196 |
| |
202 | 197 |
| |
| 198 | + | |
203 | 199 |
| |
204 | 200 |
| |
205 | 201 |
| |
206 | 202 |
| |
| 203 | + | |
| 204 | + | |
207 | 205 |
| |
208 | 206 |
| |
209 | 207 |
| |
| |||
212 | 210 |
| |
213 | 211 |
| |
214 | 212 |
| |
| 213 | + | |
215 | 214 |
| |
216 | 215 |
| |
217 | 216 |
| |
| |||
255 | 254 |
| |
256 | 255 |
| |
257 | 256 |
| |
| 257 | + | |
258 | 258 |
| |
259 | 259 |
| |
260 | 260 |
| |
| |||
271 | 271 |
| |
272 | 272 |
| |
273 | 273 |
| |
| 274 | + | |
274 | 275 |
| |
275 | 276 |
| |
276 | 277 |
| |
| |||
336 | 337 |
| |
337 | 338 |
| |
338 | 339 |
| |
| 340 | + | |
339 | 341 |
| |
340 | 342 |
| |
341 | 343 |
| |
| |||
349 | 351 |
| |
350 | 352 |
| |
351 | 353 |
| |
| 354 | + | |
| 355 | + | |
352 | 356 |
| |
353 | 357 |
| |
354 | 358 |
| |
355 | 359 |
| |
356 | 360 |
| |
357 | 361 |
| |
| 362 | + | |
358 | 363 |
| |
359 | 364 |
| |
360 | 365 |
| |
| |||
381 | 386 |
| |
382 | 387 |
| |
383 | 388 |
| |
| 389 | + | |
384 | 390 |
| |
385 | 391 |
| |
386 | 392 |
| |
| |||
409 | 415 |
| |
410 | 416 |
| |
411 | 417 |
| |
412 |
| - | |
413 | 418 |
| |
414 | 419 |
| |
415 |
| - | |
416 | 420 |
| |
417 |
| - | |
418 | 421 |
| |
419 | 422 |
| |
420 | 423 |
| |
421 | 424 |
| |
422 | 425 |
| |
423 |
| - | |
424 | 426 |
| |
425 | 427 |
| |
426 | 428 |
| |
|
0 commit comments