Commit 5e031ce
committed
merge to latest master branch from spark-9104-draft
File tree
1,519 files changed
+33816
-20983
lines changed- R/pkg
- R
- inst/tests/testthat
- assembly
- bagel
- src/main/scala/org/apache/spark/bagel
- bin
- build
- core
- src
- main
- java/org/apache/spark
- api/java
- util/collection/unsafe/sort
- resources/org/apache/spark/ui/static
- scala/org/apache/spark
- api
- java
- python
- r
- broadcast
- deploy
- client
- history
- master
- ui
- mesos
- ui
- rest
- mesos
- worker
- ui
- executor
- input
- io
- mapreduce
- mapred
- memory
- metrics
- sink
- network
- netty
- partial
- rdd
- rpc
- akka
- netty
- scheduler
- cluster
- mesos
- serializer
- shuffle
- hash
- sort
- status/api/v1
- storage
- ui
- exec
- jobs
- scope
- storage
- util
- collection
- logging
- random
- test
- java/org/apache/spark
- api/java
- memory
- shuffle/sort
- unsafe/map
- util/collection/unsafe/sort
- resources/HistoryServerExpectations
- scala/org/apache/spark
- api/python
- broadcast
- deploy
- client
- history
- master
- ui
- rest
- worker
- input
- io
- memory
- metrics
- network/netty
- rdd
- rpc
- akka
- netty
- scheduler
- cluster/mesos
- mesos
- serializer
- shuffle/sort
- status/api/v1
- storage
- ui
- scope
- storage
- util
- collection
- unsafe/sort
- random
- data/streaming
- dev
- audit-release
- create-release
- deps
- sparktestsupport
- tests
- docker-integration-tests
- src/test/scala/org/apache/spark
- sql/jdbc
- util
- docs
- _data
- _includes
- _layouts
- css
- js
- ec2
- examples
- src/main
- java/org/apache/spark/examples
- mllib
- ml
- streaming
- python
- mllib
- ml
- streaming
- r
- scala/org/apache/spark/examples
- graphx
- mllib
- ml
- pythonconverters
- sql/hive
- streaming
- clickstream
- external
- flume-assembly
- 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-assembly
- kafka
- src
- main/scala/org/apache/spark/streaming/kafka
- test
- java/org/apache/spark/streaming/kafka
- scala/org/apache/spark/streaming/kafka
- mqtt-assembly
- mqtt
- src
- main/scala/org/apache/spark/streaming/mqtt
- test/scala/org/apache/spark/streaming/mqtt
- twitter
- src
- main/scala/org/apache/spark/streaming/twitter
- test/scala/org/apache/spark/streaming/twitter
- zeromq
- src/main/scala/org/apache/spark/streaming/zeromq
- extras
- java8-tests
- src/test/java/org/apache/spark
- streaming
- kinesis-asl-assembly
- kinesis-asl
- src
- main/scala/org/apache/spark
- examples/streaming
- streaming/kinesis
- test/scala/org/apache/spark/streaming/kinesis
- spark-ganglia-lgpl
- graphx
- src
- main/scala/org/apache/spark/graphx
- impl
- lib
- util
- collection
- test/scala/org/apache/spark/graphx
- impl
- launcher
- src/main/java/org/apache/spark/launcher
- mllib
- src
- main/scala/org/apache/spark
- mllib
- api/python
- classification
- clustering
- evaluation
- feature
- fpm
- impl
- linalg
- distributed
- optimization
- pmml/export
- random
- rdd
- regression
- stat
- distribution
- test
- tree
- configuration
- impl
- model
- util
- ml
- ann
- attribute
- classification
- clustering
- evaluation
- feature
- param
- recommendation
- regression
- r
- source/libsvm
- tree
- impl
- tuning
- test
- java/org/apache/spark/mllib
- fpm
- recommendation
- regression
- stat
- scala/org/apache/spark
- mllib
- api/python
- classification
- clustering
- evaluation
- feature
- fpm
- linalg
- distributed
- optimization
- random
- rdd
- regression
- stat
- distribution
- tree
- util
- ml
- classification
- evaluation
- feature
- impl
- param
- recommendation
- 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
- linalg
- ml
- param
- 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
- antlr3/org/apache/spark/sql/catalyst/parser
- java/org/apache/spark/sql
- catalyst
- expressions
- parser
- execution
- scala/org/apache/spark/sql
- catalyst
- analysis
- dsl
- encoders
- expressions
- aggregate
- codegen
- optimizer
- parser
- plans
- logical
- physical
- rules
- trees
- util
- types
- test/scala/org/apache/spark/sql
- catalyst
- analysis
- encoders
- expressions
- aggregate
- codegen
- optimizer
- plans
- trees
- util
- types
- core
- src
- main
- java/org/apache/spark/sql/execution
- datasources/parquet
- scala/org/apache/spark/sql
- api/r
- execution
- aggregate
- columnar
- compression
- datasources
- jdbc
- json
- parquet
- text
- debug
- joins
- local
- metric
- stat
- ui
- expressions
- jdbc
- sources
- test
- util
- test
- java/test/org/apache/spark/sql
- scala/org/apache/spark/sql
- execution
- columnar
- compression
- datasources
- json
- parquet
- text
- joins
- local
- ui
- jdbc
- sources
- test
- hive-thriftserver
- src
- main/scala/org/apache
- hive/service/server
- spark/sql/hive/thriftserver
- server
- ui
- 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
- client
- execution
- orc
- test
- test/scala/org/apache/spark/sql
- hive
- client
- execution
- orc
- sources
- streaming
- src
- main/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
- receiver
- scheduler
- util
- tags
- tools
- src/main/scala/org/apache/spark/tools
- unsafe
- src/test/scala/org/apache/spark/unsafe/types
- yarn
- src
- main/scala/org/apache/spark
- deploy/yarn
- scheduler/cluster
- test/scala/org/apache/spark
- deploy/yarn
- network
- shuffle
- yarn
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
1,519 files changed
+33816
-20983
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
60 | 60 | | |
61 | 61 | | |
62 | 62 | | |
63 | | - | |
64 | 63 | | |
65 | 64 | | |
66 | 65 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
84 | 84 | | |
85 | 85 | | |
86 | 86 | | |
| 87 | + | |
| 88 | + | |
| 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 | | |
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 | + | |
| 98 | + | |
96 | 99 | | |
97 | 100 | | |
98 | 101 | | |
| |||
127 | 130 | | |
128 | 131 | | |
129 | 132 | | |
| 133 | + | |
130 | 134 | | |
131 | 135 | | |
132 | 136 | | |
| |||
267 | 271 | | |
268 | 272 | | |
269 | 273 | | |
| 274 | + | |
270 | 275 | | |
271 | 276 | | |
272 | 277 | | |
| 278 | + | |
| 279 | + | |
273 | 280 | | |
274 | 281 | | |
275 | 282 | | |
| |||
0 commit comments