File tree
795 files changed
+8635
-5869
lines changed- R- pkg- R
- inst- profile
- tests
 
- src-native
 
 
- bagel- src/test/scala/org/apache/spark/bagel
 
- bin
- conf
- core- src- main- java/org/apache/spark/shuffle/sort
- resources/org/apache/spark/ui/static
- scala/org/apache/spark- api- java
- python
- r
 
- broadcast
- deploy- master/ui
- rest
- worker
 
- executor
- mapreduce
- network/nio
- partial
- rdd
- scheduler- cluster- mesos
 
 
- serializer
- shuffle/sort
- status/api/v1
- storage
- ui- jobs
- storage
 
- util- collection
- random
 
 
 
- test- java/org/apache/spark
- scala/org/apache/spark- api/python
- broadcast
- deploy- history
- master
- rest
- worker
 
- executor
- input
- io
- metrics
- network- netty
- nio
 
- rdd
- rpc
- scheduler- cluster/mesos
- mesos
 
- serializer
- shuffle- hash
- sort
- unsafe
 
- status/api/v1
- storage
- ui- jobs
- scope
- storage
 
- util- collection
- io
- random
 
 
 
 
 
- data/mllib
- dev- create-release
 
- docs- _layouts
- _plugins
 
- ec2
- examples- src/main- java/org/apache/spark/examples- ml
- streaming
 
- python- ml
 
- scala/org/apache/spark/examples- bagel
- mllib
- ml
- pythonconverters
- streaming- clickstream
 
 
 
 
- external- flume-sink/src- main/scala/org/apache/spark/streaming/flume/sink
- test/scala/org/apache/spark/streaming/flume/sink
 
- flume- src- main/scala/org/apache/spark/streaming/flume
- test/scala/org/apache/spark/streaming/flume
 
 
- kafka- src/test/scala/org/apache/spark/streaming/kafka
 
- mqtt- src- main/scala/org/apache/spark/streaming/mqtt
- test/scala/org/apache/spark/streaming/mqtt
 
 
- twitter- src/test/scala/org/apache/spark/streaming/twitter
 
- zeromq- src/test/scala/org/apache/spark/streaming/zeromq
 
 
- extras/kinesis-asl/src/main/scala/org/apache/spark- examples/streaming
- streaming/kinesis
 
- graphx- src- main/scala/org/apache/spark/graphx- impl
- lib
- util
 
- test/scala/org/apache/spark/graphx- impl
- lib
- util
 
 
 
- launcher/src/main/java/org/apache/spark/launcher
- mllib- src- main/scala/org/apache/spark- mllib- api/python
- clustering
- feature
- linalg- distributed
 
- random
- regression
- stat- test
 
- tree- model
 
- util
 
- ml- attribute
- classification
- evaluation
- feature
- param
- recommendation
- regression
- tree
- tuning
 
 
- test- java/org/apache/spark/ml- feature
- util
 
- scala/org/apache/spark- mllib- api/python
- classification
- clustering
- evaluation
- feature
- fpm
- impl
- linalg- distributed
 
- optimization
- pmml/export
- random
- rdd
- recommendation
- regression
- stat- distribution
 
- tree- impl
 
- util
 
- ml- attribute
- classification
- evaluation
- feature
- impl
- param
- recommendation
- regression
- tuning
 
 
 
 
 
- project
- python- pyspark- mllib
- ml
- sql
 
 
- repl- scala-2.10/src/test/scala/org/apache/spark/repl
- scala-2.11/src/test/scala/org/apache/spark/repl
- src/test/scala/org/apache/spark/repl
 
- sql- catalyst- src- main/scala/org/apache/spark/sql- catalyst- analysis
- dsl
- errors
- expressions- codegen
- mathfuncs
 
- plans- logical
- physical
 
- trees
- util
 
- types
 
- test/scala/org/apache/spark/sql- catalyst- analysis
- expressions
- optimizer
- plans
- trees
- util
 
- types- decimal
 
 
 
 
- core- src- main/scala/org/apache/spark/sql- columnar
- execution- expressions
- joins
- stat
 
- jdbc
- json
- parquet
- sources
- test
 
- test/scala/org/apache/spark/sql- columnar- compression
 
- execution- debug
- joins
 
- jdbc
- json
- parquet
- sources
- test
 
 
 
- hive-thriftserver- src- main/scala/org/apache/spark/sql/hive/thriftserver- ui
 
- test/scala/org/apache/spark/sql/hive/thriftserver
 
- v0.12.0/src/main/scala/org/apache/spark/sql/hive/thriftserver
 
- hive- src- main/scala/org/apache/spark/sql/hive- execution
- test
 
- test/scala/org/apache/spark/sql- hive- client
- execution
- orc
 
- sources
 
 
- v0.12.0/src/main/scala/org/apache/spark/sql/hive
 
 
- streaming- src- main/scala/org/apache/spark/streaming- api/java
- dstream
- receiver
- scheduler
- util
 
- test/scala/org/apache/spark/streaming- rdd
- scheduler
- ui
- util
 
 
 
- yarn- src- main/scala/org/apache/spark/deploy/yarn
- test/scala/org/apache/spark/deploy/yarn
 
 
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
795 files changed
+8635
-5869
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
|  | |||
| 52 | 52 |  | |
| 53 | 53 |  | |
| 54 | 54 |  | |
| 55 |  | - | |
|  | 55 | + | |
| 56 | 56 |  | |
| 57 | 57 |  | |
| 58 | 58 |  | |
|  | |||
| 63 | 63 |  | |
| 64 | 64 |  | |
| 65 | 65 |  | |
| 66 |  | - | |
|  | 66 | + | |
| 67 | 67 |  | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
|  | |||
| 1 | 1 |  | |
| 2 | 2 |  | |
| 3 |  | - | |
|  | 3 | + | |
|  | 4 | + | |
|  | 5 | + | |
|  | 6 | + | |
| 4 | 7 |  | |
| 5 | 8 |  | |
| 6 | 9 |  | |
|  | |||

0 commit comments