File tree
446 files changed
+10995
-4039
lines changed- assembly
 - bagel
 - bin
 - conf
 - core
- src
- main/scala/org/apache/spark
- api
- java
 - python
 
 - deploy
- client
 - history
 - master
- ui
 
 - rest
 - worker
- ui
 
 
 - executor
 - launcher
 - rdd
 - scheduler
- cluster
- mesos
 
 - local
 
 - serializer
 - shuffle/sort
 - storage
 - ui
 - util
 
 - test
- java/org/apache/spark
 - scala/org/apache/spark
- deploy
 - rdd
 - scheduler
- cluster/mesos
 
 - serializer
 - storage
 - ui
 - util
 
 
 
 
 - dev
- create-release
 - tests
 
 - docs
- _layouts
 
 - ec2
- deploy.generic/root/spark-ec2
 
 - examples
- src/main
- java/org/apache/spark/examples/streaming
 - python/streaming
 - scala/org/apache/spark/examples
- graphx
 - mllib
 - streaming
 
 
 
 - external
- flume-sink
 - flume
 - kafka-assembly
 - kafka
- src
- main/scala/org/apache/spark/streaming/kafka
 - test
- java/org/apache/spark/streaming/kafka
 - scala/org/apache/spark/streaming/kafka
 
 
 
 - mqtt
 - twitter
 - zeromq
 
 - extras
- java8-tests
 - kinesis-asl
 - spark-ganglia-lgpl
 
 - graphx
- src
- main/scala/org/apache/spark/graphx
- impl
 - lib
 
 - test/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
 - linalg
- distributed
 
 - optimization
 - random
 - rdd
 - recommendation
 - regression
- impl
 
 - tree
- configuration
 - impurity
 - loss
 - model
 
 - util
 
 - ml
- attribute
 - feature
 - param
 - recommendation
 
 
 - test
- java/org/apache/spark/ml/attribute
 - scala/org/apache/spark
- mllib
- classification
 - clustering
 - linalg
 - optimization
 - rdd
 - stat
 - tree
 
 - ml
- attribute
 - recommendation
 
 
 
 
 
 - network
- common
- src
- main/java/org/apache/spark/network
- protocol
 - sasl
 - server
 - util
 
 - test/java/org/apache/spark/network/sasl
 
 
 - shuffle
- src
- main/java/org/apache/spark/network/shuffle
- protocol
 
 - test/java/org/apache/spark/network/shuffle
 
 
 - yarn
 
 - 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
 
 - sbin
 - sql
- catalyst
- src
- main/scala/org/apache/spark/sql
- catalyst
- analysis
 - expressions
- codegen
 
 - plans/logical
 - trees
 - util
 
 - types
 
 - test/scala/org/apache/spark/sql/catalyst
- analysis
 - plans
 
 
 
 - core
- src
- main/scala/org/apache/spark/sql
- columnar
- compression
 
 - execution
- debug
 - joins
 
 - jdbc
 - json
 - parquet
- timestamp
 
 - sources
 - test
 
 - test/scala/org/apache/spark/sql
- columnar
 - 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
- test
 
 - test
- resources/golden
 - scala/org/apache/spark/sql
- catalyst/plans
 - hive
- execution
 
 
 
 
 
 
 - streaming
- src
- main/scala/org/apache/spark/streaming
- api/java
 - scheduler
 - ui
 - util
 
 - test
- java/org/apache/spark/streaming
 - scala/org/apache/spark/streaming
- scheduler
 
 
 
 
 - tools
 - 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.
446 files changed
+10995
-4039
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 |  | |
 | |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
 | |||
85 | 85 |  | |
86 | 86 |  | |
87 | 87 |  | |
88 |  | - | |
 | 88 | + | |
89 | 89 |  | |
90 | 90 |  | |
91 | 91 |  | |
 | |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
 | |||
21 | 21 |  | |
22 | 22 |  | |
23 | 23 |  | |
24 |  | - | |
 | 24 | + | |
25 | 25 |  | |
26 | 26 |  | |
27 | 27 |  | |
 | |||
114 | 114 |  | |
115 | 115 |  | |
116 | 116 |  | |
117 |  | - | |
118 |  | - | |
119 |  | - | |
120 |  | - | |
121 |  | - | |
122 |  | - | |
123 |  | - | |
124 |  | - | |
125 |  | - | |
126 |  | - | |
127 | 117 |  | |
128 | 118 |  | |
129 | 119 |  | |
 | |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
 | |||
21 | 21 |  | |
22 | 22 |  | |
23 | 23 |  | |
24 |  | - | |
 | 24 | + | |
25 | 25 |  | |
26 | 26 |  | |
27 | 27 |  | |
 | |||
This file was deleted.
This file was deleted.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
 | |||
41 | 41 |  | |
42 | 42 |  | |
43 | 43 |  | |
44 |  | - | |
45 |  | - | |
46 |  | - | |
 | 44 | + | |
 | 45 | + | |
 | 46 | + | |
47 | 47 |  | |
48 | 48 |  | |
49 | 49 |  | |
 | |||
54 | 54 |  | |
55 | 55 |  | |
56 | 56 |  | |
57 |  | - | |
 | 57 | + | |
58 | 58 |  | |
0 commit comments