File tree
779 files changed
+22870
-10166
lines changed- R
- pkg
- R
- inst/tests/testthat
- tests
- assembly
- src/main/assembly
- bagel/src/main/scala/org/apache/spark/bagel
- bin
- build
- core
- src
- main
- java/org/apache/spark
- api/java/function
- util/collection/unsafe/sort
- resources/org/apache/spark/ui/static
- scala/org/apache/spark
- api/java
- cuda
- deploy
- client
- history
- master
- mesos
- rest
- worker
- executor
- io
- mapreduce
- memory
- network/netty
- rdd
- rpc
- akka
- netty
- scheduler
- cluster
- serializer
- shuffle
- hash
- sort
- status/api/v1
- storage
- ui
- exec
- scope
- util
- collection
- random
- test
- java/org/apache/spark
- memory
- shuffle/sort
- unsafe/map
- util/collection/unsafe/sort
- resources/HistoryServerExpectations
- scala/org/apache/spark
- deploy
- io
- memory
- network/netty
- rdd
- rpc
- netty
- scheduler
- serializer
- status/api/v1
- storage
- util
- data/streaming
- dev
- audit-release
- create-release
- sparktestsupport
- docker-integration-tests
- docs
- _data
- _includes
- _layouts
- _plugins
- css
- js
- ec2
- examples
- src/main
- java/org/apache/spark/examples
- ml
- mllib
- streaming
- python
- ml
- mllib
- streaming
- r
- scala/org/apache/spark/examples
- ml
- mllib
- pythonconverters
- streaming
- clickstream
- external
- flume
- src
- main/scala/org/apache/spark/streaming/flume
- test/scala/org/apache/spark/streaming/flume
- flume-assembly
- flume-sink
- src/test/scala/org/apache/spark/streaming/flume/sink
- kafka
- src/main/scala/org/apache/spark/streaming/kafka
- kafka-assembly
- mqtt
- src/main/assembly
- mqtt-assembly
- twitter
- zeromq
- extras
- java8-tests
- src/test/java/org/apache/spark/streaming
- kinesis-asl
- src
- main/scala/org/apache/spark/streaming/kinesis
- test/scala/org/apache/spark/streaming/kinesis
- kinesis-asl-assembly
- spark-ganglia-lgpl
- graphx
- src/test/scala/org/apache/spark/graphx
- lib
- launcher
- src/main/java/org/apache/spark/launcher
- mllib
- src
- main/scala/org/apache/spark
- ml
- classification
- evaluation
- feature
- param
- regression
- tuning
- mllib
- api/python
- classification
- impl
- clustering
- feature
- linalg/distributed
- optimization
- pmml/export
- recommendation
- regression
- impl
- stat/test
- tree/model
- util
- test
- java/org/apache/spark
- ml/feature
- mllib
- clustering
- stat
- scala/org/apache/spark
- ml
- classification
- evaluation
- feature
- impl
- regression
- tuning
- mllib
- feature
- linalg/distributed
- stat
- tree
- network
- common
- src
- main/java/org/apache/spark/network
- client
- protocol
- sasl
- server
- util
- test/java/org/apache/spark/network
- sasl
- util
- shuffle
- src
- main/java/org/apache/spark/network/shuffle
- mesos
- protocol
- test/java/org/apache/spark/network
- sasl
- shuffle
- yarn
- project
- project
- python
- pyspark
- ml
- mllib
- sql
- streaming
- repl
- scala-2.10/src/main/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/scala/org/apache/spark/repl
- sql
- catalyst
- src
- main
- java/org/apache/spark/sql
- execution
- types
- scala/org/apache/spark/sql
- catalyst
- analysis
- dsl
- encoders
- expressions
- aggregate
- codegen
- optimizer
- planning
- plans
- logical
- trees
- util
- types
- test/scala/org/apache/spark/sql/catalyst
- analysis
- encoders
- expressions
- codegen
- optimizer
- trees
- core
- src
- main
- java/org/apache/spark/sql/execution/datasources/parquet
- scala/org/apache/spark/sql
- execution
- aggregate
- columnar
- datasources
- jdbc
- json
- parquet
- text
- joins
- local
- ui
- expressions
- jdbc
- sources
- test
- java/test/org/apache/spark/sql
- scala/org/apache/spark/sql
- execution
- columnar
- compression
- datasources
- json
- parquet
- metric
- ui
- jdbc
- sources
- test
- hive
- 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/test
- scala/org/apache/spark/sql/hive
- client
- execution
- orc
- hive-thriftserver
- src
- main/scala/org/apache/spark/sql/hive/thriftserver
- test/scala/org/apache/spark/sql/hive/thriftserver
- streaming
- src
- main
- java/org/apache/spark/streaming/util
- scala/org/apache/spark/streaming
- api
- java
- python
- dstream
- rdd
- receiver
- scheduler
- ui
- util
- test
- java/org/apache/spark/streaming
- scala/org/apache/spark/streaming
- rdd
- util
- tags
- src/main/java/org/apache/spark/tags
- tools
- unsafe
- src
- main/java/org/apache/spark/unsafe
- types
- test/java/org/apache/spark/unsafe
- yarn
- src
- main/scala/org/apache/spark
- deploy/yarn
- scheduler/cluster
- test/scala/org/apache/spark
- deploy/yarn
- scheduler/cluster
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
779 files changed
+22870
-10166
lines changedOriginal file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
84 | 84 |
| |
85 | 85 |
| |
86 | 86 |
| |
| 87 | + |
+1-2
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 |
| - | |
2 | 1 |
| |
3 | 2 |
| |
4 | 3 |
| |
| |||
237 | 236 |
| |
238 | 237 |
| |
239 | 238 |
| |
240 |
| - | |
| 239 | + | |
241 | 240 |
| |
242 | 241 |
| |
243 | 242 |
| |
|
+8-1
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
606 | 606 |
| |
607 | 607 |
| |
608 | 608 |
| |
609 |
| - | |
| 609 | + | |
| 610 | + | |
| 611 | + | |
| 612 | + | |
| 613 | + | |
| 614 | + | |
| 615 | + | |
| 616 | + |
+1-1
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 |
| - | |
| 1 | + | |
2 | 2 |
|
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 | 1 |
| |
2 | 2 |
| |
3 | 3 |
| |
4 |
| - | |
| 4 | + | |
5 | 5 |
| |
6 | 6 |
| |
7 | 7 |
| |
|
+17-6
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
27 | 27 |
| |
28 | 28 |
| |
29 | 29 |
| |
| 30 | + | |
| 31 | + | |
30 | 32 |
| |
| 33 | + | |
31 | 34 |
| |
32 | 35 |
| |
33 | 36 |
| |
| |||
56 | 59 |
| |
57 | 60 |
| |
58 | 61 |
| |
| 62 | + | |
59 | 63 |
| |
60 | 64 |
| |
61 | 65 |
| |
| |||
88 | 92 |
| |
89 | 93 |
| |
90 | 94 |
| |
91 |
| - | |
| 95 | + | |
| 96 | + | |
| 97 | + | |
92 | 98 |
| |
93 | 99 |
| |
94 | 100 |
| |
| |||
123 | 129 |
| |
124 | 130 |
| |
125 | 131 |
| |
126 |
| - | |
| 132 | + | |
127 | 133 |
| |
128 | 134 |
| |
129 | 135 |
| |
130 | 136 |
| |
131 | 137 |
| |
132 | 138 |
| |
133 |
| - | |
| 139 | + | |
| 140 | + | |
134 | 141 |
| |
| 142 | + | |
135 | 143 |
| |
136 | 144 |
| |
137 | 145 |
| |
| |||
188 | 196 |
| |
189 | 197 |
| |
190 | 198 |
| |
191 |
| - | |
| 199 | + | |
192 | 200 |
| |
193 | 201 |
| |
194 | 202 |
| |
| |||
200 | 208 |
| |
201 | 209 |
| |
202 | 210 |
| |
203 |
| - | |
| 211 | + | |
204 | 212 |
| |
205 | 213 |
| |
206 | 214 |
| |
| |||
221 | 229 |
| |
222 | 230 |
| |
223 | 231 |
| |
| 232 | + | |
224 | 233 |
| |
225 | 234 |
| |
226 | 235 |
| |
| |||
260 | 269 |
| |
261 | 270 |
| |
262 | 271 |
| |
| 272 | + | |
263 | 273 |
| |
264 | 274 |
| |
265 | 275 |
| |
| 276 | + | |
266 | 277 |
| |
267 | 278 |
| |
268 | 279 |
| |
| |||
276 | 287 |
| |
277 | 288 |
| |
278 | 289 |
| |
279 |
| - | |
| 290 | + |
0 commit comments