Commit 601a9ea
committed
Merge branch 'master' into SPARK-11937-SPARK-11922-Python-API-for-ml.feature.QuantileDiscretizer
767 files changed
Lines changed: 21794 additions & 9334 deletions
File tree
- R
- pkg
- R
- inst/tests/testthat
- tests
- assembly
- bagel
- src/main/scala/org/apache/spark/bagel
- bin
- build
- core
- src
- main
- java/org/apache/spark
- util/collection/unsafe/sort
- resources/org/apache/spark/ui/static
- scala/org/apache/spark
- api/java
- deploy
- client
- history
- master
- mesos
- rest
- worker
- executor
- io
- mapreduce
- memory
- network/netty
- rdd
- rpc
- akka
- netty
- scheduler
- cluster
- mesos
- serializer
- shuffle
- hash
- sort
- status/api/v1
- storage
- ui
- exec
- jobs
- scope
- storage
- util
- random
- test
- java/org/apache/spark
- memory
- shuffle/sort
- unsafe/map
- util/collection/unsafe/sort
- resources/HistoryServerExpectations
- scala/org/apache/spark
- deploy
- client
- history
- rest
- input
- io
- memory
- network/netty
- rdd
- rpc
- netty
- scheduler
- serializer
- shuffle/sort
- status/api/v1
- storage
- ui
- util
- data/streaming
- dev
- audit-release
- create-release
- sparktestsupport
- tests
- docker-integration-tests
- docs
- _data
- _includes
- _layouts
- css
- js
- ec2
- examples
- src/main
- java/org/apache/spark/examples
- mllib
- ml
- streaming
- python
- ml
- streaming
- r
- scala/org/apache/spark/examples
- mllib
- ml
- pythonconverters
- streaming
- clickstream
- external
- flume-assembly
- flume-sink
- src/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-assembly
- kafka
- src/main/scala/org/apache/spark/streaming/kafka
- mqtt-assembly
- mqtt
- twitter
- zeromq
- extras
- java8-tests
- src/test/java/org/apache/spark/streaming
- kinesis-asl-assembly
- kinesis-asl
- src
- main/scala/org/apache/spark/streaming/kinesis
- test/scala/org/apache/spark/streaming/kinesis
- 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
- mllib
- api/python
- classification
- impl
- clustering
- feature
- linalg/distributed
- pmml/export
- recommendation
- regression
- impl
- stat/test
- tree/model
- util
- ml
- classification
- evaluation
- feature
- param
- regression
- tree
- tuning
- test
- java/org/apache/spark
- mllib
- clustering
- stat
- ml/feature
- scala/org/apache/spark
- mllib
- feature
- linalg/distributed
- stat
- tree
- util
- ml
- classification
- evaluation
- feature
- impl
- param
- regression
- source/libsvm
- tuning
- util
- network
- common
- src
- main/java/org/apache/spark/network
- client
- sasl
- server
- test/java/org/apache/spark/network/sasl
- shuffle
- src
- main/java/org/apache/spark/network/shuffle
- test/java/org/apache/spark/network
- sasl
- shuffle
- yarn
- project
- python
- pyspark
- mllib
- ml
- 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
- rules
- trees
- types
- test/scala/org/apache/spark/sql/catalyst
- analysis
- encoders
- expressions
- codegen
- optimizer
- core
- src
- main
- java/org/apache/spark/sql/execution/datasources/parquet
- resources/META-INF/services
- scala/org/apache/spark/sql
- api/r
- execution
- aggregate
- columnar
- datasources
- jdbc
- json
- parquet
- text
- joins
- local
- metric
- 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-thriftserver
- src
- main/scala/org/apache/spark/sql/hive/thriftserver
- test/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
- orc
- test
- test
- java/org/apache/spark/sql/hive/test
- scala/org/apache/spark/sql/hive
- execution
- orc
- streaming
- src
- main
- java/org/apache/spark/streaming/util
- scala/org/apache/spark/streaming
- api
- java
- python
- dstream
- rdd
- 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
- network/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.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
82 | 82 | | |
83 | 83 | | |
84 | 84 | | |
| 85 | + | |
85 | 86 | | |
| 87 | + | |
| 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 | | |
| |||
| 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 | + | |
| 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 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
92 | 92 | | |
93 | 93 | | |
94 | 94 | | |
95 | | - | |
| 95 | + | |
| 96 | + | |
| 97 | + | |
96 | 98 | | |
97 | 99 | | |
98 | 100 | | |
| |||
134 | 136 | | |
135 | 137 | | |
136 | 138 | | |
| 139 | + | |
137 | 140 | | |
138 | 141 | | |
| 142 | + | |
139 | 143 | | |
140 | 144 | | |
141 | 145 | | |
| |||
225 | 229 | | |
226 | 230 | | |
227 | 231 | | |
| 232 | + | |
228 | 233 | | |
229 | 234 | | |
230 | 235 | | |
| |||
264 | 269 | | |
265 | 270 | | |
266 | 271 | | |
| 272 | + | |
267 | 273 | | |
268 | 274 | | |
269 | 275 | | |
| 276 | + | |
270 | 277 | | |
271 | 278 | | |
272 | 279 | | |
| |||
0 commit comments