File tree
1,425 files changed
+77024
-24538
lines changed- R
- pkg
- R
 - inst
- profile
 - tests
 - worker
 
 - src
 - tests
 
 
 - assembly
- src/deb
- control
 
 
 - bagel
- src/test/resources
 
 - bin
 - build
 - conf
 - core
- src
- main
- java/org/apache/spark/util/collection
 - resources/org/apache/spark
- ui/static
 
 - scala/org/apache/spark
- api
- java
 - python
 - r
 
 - broadcast
 - deploy
- client
 - history
 - master
- ui
 
 - rest
 - worker
- ui
 
 
 - executor
 - input
 - io
 - launcher
 - mapreduce
 - mapred
 - metrics
- sink
 
 - network/nio
 - partial
 - rdd
 - rpc
- akka
 
 - scheduler
- cluster
- mesos
 
 - local
 
 - serializer
 - shuffle
- hash
 - sort
 
 - storage
 - ui
- exec
 - jobs
 - storage
 
 - util
- collection
 - logging
 - random
 
 
 
 - test
- java/org/apache/spark
- util/collection
 
 - resources
 - scala/org/apache/spark
- broadcast
 - deploy
- history
 - rest
 - worker
 
 - executor
 - input
 - metrics
 - network/nio
 - rdd
 - rpc
- akka
 
 - scheduler
- cluster/mesos
 
 - serializer
 - shuffle/hash
 - storage
 - ui
- jobs
 - storage
 
 - util
- collection
 - random
 
 
 
 
 
 - data/mllib
- als
 
 - dev
- audit-release/sbt_app_sql/src/main/scala
 - create-release
 - tests
 
 - docs
- _layouts
 - _plugins
 - img
 
 - ec2
- deploy.generic/root/spark-ec2
 
 - examples
- scala-2.10/src/main
- java/org/apache/spark/examples/streaming
 - scala/org/apache/spark/examples/streaming
 
 - src/main
- java/org/apache/spark/examples
- mllib
 - ml
 - sql
 - streaming
 
 - python
- mllib
 - ml
 - streaming
 
 - r
 - scala/org/apache/spark/examples
- bagel
 - graphx
 - mllib
 - ml
 - sql
- hive
 
 - streaming
- clickstream
 
 
 
 
 - external
- flume-sink
- src/test/resources
 
 - flume
- src
- main/scala/org/apache/spark/streaming/flume
 - test
- java/org/apache/spark/streaming
 - resources
 - scala/org/apache/spark/streaming/flume
 
 
 
 - kafka-assembly
 - kafka
- src
- main/scala/org/apache/spark/streaming/kafka
 - test
- java/org/apache/spark/streaming/kafka
 - resources
 - scala/org/apache/spark/streaming/kafka
 
 
 
 - mqtt
- src
- main/scala/org/apache/spark/streaming/mqtt
 - test
- java/org/apache/spark/streaming
 - resources
 - scala/org/apache/spark/streaming/mqtt
 
 
 
 - twitter
- src
- main/scala/org/apache/spark/streaming/twitter
 - test
- java/org/apache/spark/streaming
 - resources
 
 
 
 - zeromq
- src
- main/scala/org/apache/spark/streaming/zeromq
 - test
- java/org/apache/spark/streaming
 - resources
 
 
 
 
 - extras
- java8-tests
- src/test/resources
 
 - kinesis-asl
- src
- main
- resources
 - scala/org/apache/spark/streaming/kinesis
 
 - test
- resources
 - scala/org/apache/spark/streaming/kinesis
 
 
 
 - spark-ganglia-lgpl
 
 - graphx
- src
- main/scala/org/apache/spark/graphx
- impl
 - lib
 - util/collection
 
 - test
- resources
 - scala/org/apache/spark/graphx
- lib
 
 
 
 
 - launcher
- src
- main/java/org/apache/spark/launcher
 - test
- java/org/apache/spark/launcher
 - resources
 
 
 
 - mllib
- src
- main/scala/org/apache/spark
- mllib
- api/python
 - classification
- impl
 
 - clustering
 - evaluation
 - feature
 - fpm
 - linalg
- distributed
 
 - optimization
 - random
 - rdd
 - recommendation
 - regression
- impl
 
 - stat
- distribution
 
 - tree
- configuration
 - impl
 - impurity
 - loss
 - model
 
 - util
 
 - ml
- attribute
 - classification
 - evaluation
 - feature
 - impl
- estimator
 - tree
 
 - param
 - recommendation
 - regression
 - tree
 - tuning
 - util
 
 
 - test
- java/org/apache/spark
- mllib
- classification
 - fpm
 - regression
 
 - ml
- attribute
 - classification
 - feature
 - regression
 - tuning
 
 
 - resources
 - scala/org/apache/spark
- mllib
- classification
 - clustering
 - feature
 - fpm
 - linalg
 - optimization
 - random
 - rdd
 - recommendation
 - regression
 - stat
 - tree
 - util
 
 - ml
- attribute
 - classification
 - feature
 - impl
 - param
 - recommendation
 - regression
 - util
 
 
 
 
 
 - network
- common
- src
- main/java/org/apache/spark/network
- protocol
 - sasl
 - server
 - util
 
 - test
- java/org/apache/spark/network
- protocol
 - sasl
 
 - resources
 
 
 
 - shuffle
- src
- main/java/org/apache/spark/network/shuffle
- protocol
 
 - test/java/org/apache/spark/network/shuffle
 
 
 - yarn
 
 - project
- project
 
 - python
- docs
 - pyspark
- mllib
- stat
 
 - ml
- param
 
 - sql
 - streaming
 
 - test_support
 
 - repl
- scala-2.10/src
- main/scala/org/apache/spark/repl
 - test/scala/org/apache/spark/repl
 
 - scala-2.11/src
- main/scala/org/apache/spark/repl
 - test/scala/org/apache/spark/repl
 
 - src
- main/scala/org/apache/spark/repl
 - test
- resources
 - scala/org/apache/spark/repl
 
 
 
 - sbin
 - sql
- catalyst
- src
- main/scala/org/apache/spark/sql
- catalyst
- analysis
 - dsl
 - expressions
- codegen
 
 - optimizer
 - planning
 - plans
- logical
 - physical
 
 - trees
 - util
 
 - types
 
 - test
- resources
 - scala/org/apache/spark/sql
- catalyst
- analysis
 - expressions
 - optimizer
 - plans
 - trees
 - util
 
 - types
 
 
 
 
 - core
- src
- main
- java/org/apache/spark/sql
- jdbc
 
 - scala/org/apache/spark/sql
- api
- r
 
 - columnar
- compression
 
 - execution
- debug
 - joins
 
 - jdbc
 - json
 - parquet
- timestamp
 
 - sources
 - test
 
 
 - test
- java
- org/apache/spark/sql
- api/java
 - jdbc
 
 - test/org/apache/spark/sql
- sources
 
 
 - resources
 - scala/org/apache/spark/sql
- columnar
- compression
 
 - execution
- debug
 
 - jdbc
 - json
 - parquet
 - sources
 
 
 
 
 - hive-thriftserver
- src
- main/scala/org/apache/spark/sql/hive/thriftserver
 - test/scala/org/apache/spark/sql/hive/thriftserver
 
 - v0.12.0/src/main/scala/org/apache/spark/sql/hive/thriftserver
 - v0.13.1/src/main/scala/org/apache/spark/sql/hive/thriftserver
 
 - hive
- compatibility/src/test/scala/org/apache/spark/sql/hive/execution
 - src
- main/scala/org/apache/spark/sql/hive
- execution
 - parquet
 - test
 
 - test
- java/org/apache/spark/sql/hive
 - resources
- golden
 
 - scala/org/apache/spark/sql
- catalyst/plans
 - hive
- execution
 
 - parquet
 
 
 
 - v0.12.0/src/main/scala/org/apache/spark/sql/hive
 - v0.13.1/src/main/scala/org/apache/spark/sql/hive
 
 
 - streaming
- src
- main/scala/org/apache/spark/streaming
- api
- java
 - python
 
 - dstream
 - rdd
 - receiver
 - scheduler
 - ui
 - util
 
 - test
- java/org/apache/spark/streaming
 - resources
 - scala/org/apache/spark
- streamingtest
 - streaming
- rdd
 - scheduler
 - ui
 - util
 
 
 
 
 
 - tools
- src/main/scala/org/apache/spark/tools
 
 - yarn
- src
- main/scala/org/apache/spark
- deploy/yarn
 - scheduler/cluster
 
 - test
- resources
 - 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.
1,425 files changed
+77024
-24538
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
 | |||
6 | 6 |  | |
7 | 7 |  | |
8 | 8 |  | |
 | 9 | + | |
9 | 10 |  | |
10 | 11 |  | |
11 | 12 |  | |
 | |||
62 | 63 |  | |
63 | 64 |  | |
64 | 65 |  | |
 | 66 | + | |
 | 67 | + | |
65 | 68 |  | |
66 | 69 |  | |
67 | 70 |  | |
 | |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
 | |||
1 | 1 |  | |
 | 2 | + | |
2 | 3 |  | |
3 | 4 |  | |
4 | 5 |  | |
 | |||
18 | 19 |  | |
19 | 20 |  | |
20 | 21 |  | |
 | 22 | + | |
21 | 23 |  | |
22 | 24 |  | |
23 | 25 |  | |
 | |||
65 | 67 |  | |
66 | 68 |  | |
67 | 69 |  | |
 | 70 | + | |
 | 71 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
 | |||
771 | 771 |  | |
772 | 772 |  | |
773 | 773 |  | |
 | 774 | + | |
 | 775 | + | |
 | 776 | + | |
 | 777 | + | |
 | 778 | + | |
 | 779 | + | |
 | 780 | + | |
 | 781 | + | |
 | 782 | + | |
 | 783 | + | |
 | 784 | + | |
 | 785 | + | |
 | 786 | + | |
 | 787 | + | |
 | 788 | + | |
 | 789 | + | |
774 | 790 |  | |
775 | 791 |  | |
776 | 792 |  | |
 | |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
 | |||
 | 1 | + | |
 | 2 | + | |
 | 3 | + | |
 | 4 | + | |
 | 5 | + | |
 | 6 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
 | |||
 | 1 | + | |
 | 2 | + | |
 | 3 | + | |
 | 4 | + | |
 | 5 | + | |
 | 6 | + | |
 | 7 | + | |
 | 8 | + | |
 | 9 | + | |
 | 10 | + | |
 | 11 | + | |
 | 12 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
 | |||
 | 1 | + | |
 | 2 | + | |
 | 3 | + | |
 | 4 | + | |
 | 5 | + | |
 | 6 | + | |
 | 7 | + | |
 | 8 | + | |
 | 9 | + | |
 | 10 | + | |
 | 11 | + | |
 | 12 | + | |
 | 13 | + | |
 | 14 | + | |
 | 15 | + | |
 | 16 | + | |
 | 17 | + | |
 | 18 | + | |
 | 19 | + | |
 | 20 | + | |
 | 21 | + | |
 | 22 | + | |
 | 23 | + | |
 | 24 | + | |
 | 25 | + | |
 | 26 | + | |
 | 27 | + | |
 | 28 | + | |
 | 29 | + | |
 | 30 | + | |
 | 31 | + | |
 | 32 | + | |
 | 33 | + | |
 | 34 | + | |
 | 35 | + | |
 | 36 | + | |
 | 37 | + | |
 | 38 | + | |
 | 39 | + | |
 | 40 | + | |
 | 41 | + | |
 | 42 | + | |
 | 43 | + | |
 | 44 | + | |
 | 45 | + | |
 | 46 | + | |
 | 47 | + | |
 | 48 | + | |
 | 49 | + | |
 | 50 | + | |
 | 51 | + | |
 | 52 | + | |
 | 53 | + | |
 | 54 | + | |
 | 55 | + | |
 | 56 | + | |
 | 57 | + | |
 | 58 | + | |
 | 59 | + | |
 | 60 | + | |
 | 61 | + | |
 | 62 | + | |
 | 63 | + | |
 | 64 | + | |
 | 65 | + | |
 | 66 | + | |
 | 67 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
 | |||
 | 1 | + | |
 | 2 | + | |
 | 3 | + | |
 | 4 | + | |
 | 5 | + | |
 | 6 | + | |
 | 7 | + | |
 | 8 | + | |
 | 9 | + | |
 | 10 | + | |
 | 11 | + | |
 | 12 | + | |
 | 13 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
 | |||
 | 1 | + | |
 | 2 | + | |
 | 3 | + | |
 | 4 | + | |
 | 5 | + | |
 | 6 | + | |
 | 7 | + | |
 | 8 | + | |
 | 9 | + | |
 | 10 | + | |
 | 11 | + | |
 | 12 | + | |
 | 13 | + | |
 | 14 | + | |
 | 15 | + | |
 | 16 | + | |
 | 17 | + | |
 | 18 | + | |
 | 19 | + | |
 | 20 | + | |
 | 21 | + | |
 | 22 | + | |
 | 23 | + | |
 | 24 | + | |
 | 25 | + | |
 | 26 | + | |
 | 27 | + | |
 | 28 | + | |
 | 29 | + | |
 | 30 | + | |
 | 31 | + | |
 | 32 | + | |
 | 33 | + | |
 | 34 | + | |
 | 35 | + | |
 | 36 | + | |
 | 37 | + | |
 | 38 | + | |
 | 39 | + | |
 | 40 | + | |
 | 41 | + | |
 | 42 | + | |
 | 43 | + | |
 | 44 | + | |
 | 45 | + | |
 | 46 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
 | |||
 | 1 | + | |
 | 2 | + | |
 | 3 | + | |
 | 4 | + | |
 | 5 | + | |
 | 6 | + | |
 | 7 | + | |
 | 8 | + | |
 | 9 | + | |
 | 10 | + | |
 | 11 | + | |
 | 12 | + | |
 | 13 | + | |
 | 14 | + | |
 | 15 | + | |
 | 16 | + | |
 | 17 | + | |
 | 18 | + | |
 | 19 | + | |
 | 20 | + | |
 | 21 | + | |
 | 22 | + | |
 | 23 | + | |
 | 24 | + | |
 | 25 | + | |
 | 26 | + | |
 | 27 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
 | |||
 | 1 | + | |
 | 2 | + | |
 | 3 | + | |
 | 4 | + | |
 | 5 | + | |
 | 6 | + | |
 | 7 | + | |
 | 8 | + | |
 | 9 | + | |
 | 10 | + | |
 | 11 | + | |
 | 12 | + | |
 | 13 | + | |
 | 14 | + | |
 | 15 | + | |
 | 16 | + | |
 | 17 | + | |
 | 18 | + | |
 | 19 | + | |
 | 20 | + | |
 | 21 | + | |
 | 22 | + | |
 | 23 | + | |
 | 24 | + | |
 | 25 | + | |
 | 26 | + | |
 | 27 | + | |
 | 28 | + | |
 | 29 | + | |
 | 30 | + | |
 | 31 | + | |
 | 32 | + | |
 | 33 | + | |
 | 34 | + | |
 | 35 | + | |
 | 36 | + | |
0 commit comments