Repository navigation
Commit 7d19977
committed
Merge remote-tracking branch 'upstream/master' into arrow-toPandas-oo-batches-SPARK-25274
1,076 files changed
Lines changed: 32995 additions & 28583 deletions
File tree
- R
- pkg
- R
- tests
- fulltests
- vignettes
- assembly
- bin
- build
- common
- kvstore
- src
- main/java/org/apache/spark/util/kvstore
- test/java/org/apache/spark/util/kvstore
- network-common
- src
- main/java/org/apache/spark/network
- buffer
- crypto
- server
- util
- test/java/org/apache/spark/network
- crypto
- network-shuffle
- src
- main/java/org/apache/spark/network/shuffle
- test/java/org/apache/spark/network/shuffle
- network-yarn
- src/main/java/org/apache/spark/network/yarn
- sketch
- src/main/java/org/apache/spark/util/sketch
- tags
- unsafe
- src
- main/java/org/apache/spark
- sql/catalyst/expressions
- unsafe
- array
- hash
- memory
- types
- test
- java/org/apache/spark/unsafe
- array
- hash
- memory
- types
- scala/org/apache/spark/unsafe/types
- core
- benchmarks
- src
- main
- java/org/apache/spark
- api/java
- io
- memory
- shuffle/sort
- util/collection/unsafe/sort
- resources/org/apache/spark/ui/static
- scala/org/apache/spark
- api
- java
- python
- r
- deploy
- history
- rest
- worker
- executor
- input
- internal/config
- io
- memory
- metrics
- sink
- network
- netty
- rdd
- scheduler
- cluster
- security
- shuffle/sort
- status
- api/v1
- storage
- ui
- jobs
- util
- io
- test
- java
- org/apache/spark
- memory
- shuffle/sort
- unsafe/map
- test/org/apache/spark
- resources
- HistoryServerExpectations
- spark-events
- scala/org/apache
- sparktest
- spark
- api/python
- benchmark
- deploy
- history
- master/ui
- rest
- executor
- rdd
- scheduler
- security
- serializer
- status
- storage
- ui
- util
- collection
- unsafe/sort
- data/mllib/images
- origin
- kittens
- multi-channel
- partitioned
- cls=kittens
- date=2018-01
- date=2018-02
- cls=multichannel
- date=2018-01
- date=2018-02
- dev
- create-release
- spark-rm
- deps
- sparktestsupport
- docs
- _data
- _includes
- _layouts
- js
- examples
- src/main
- java/org/apache/spark/examples
- ml
- sql
- python
- ml
- sql
- streaming
- resources
- r
- ml
- scala/org/apache/spark/examples
- ml
- sql
- external
- avro
- src
- main/scala/org/apache/spark/sql/avro
- test/scala/org/apache/spark/sql
- avro
- execution/benchmark
- docker-integration-tests
- src/test/scala/org/apache/spark/sql/jdbc
- flume-assembly
- flume-sink
- src
- main
- avro
- scala/org/apache/spark/streaming/flume/sink
- test
- resources
- scala/org/apache/spark/streaming/flume/sink
- flume
- src
- main
- java/org/apache/spark/examples
- scala/org/apache/spark
- examples
- streaming/flume
- test
- java/org/apache/spark/streaming
- flume
- scala/org/apache/spark/streaming
- flume
- kafka-0-10-assembly
- kafka-0-10-sql
- src
- main/scala/org/apache/spark/sql/kafka010
- test/scala/org/apache/spark/sql/kafka010
- kafka-0-10
- src
- main/scala/org/apache/spark/streaming/kafka010
- test/scala/org/apache/spark/streaming/kafka010
- kafka-0-8-assembly
- kafka-0-8
- src
- main/scala/org/apache/spark/streaming/kafka
- test
- java/org/apache/spark/streaming/kafka
- scala/org/apache/spark/streaming/kafka
- kinesis-asl-assembly
- kinesis-asl
- src
- main/java/org/apache/spark/examples/streaming
- test/scala/org/apache/spark/streaming/kinesis
- spark-ganglia-lgpl
- src/main/scala/org/apache/spark/metrics/sink
- graphx
- src/main/scala/org/apache/spark/graphx/lib
- hadoop-cloud
- launcher
- mllib-local
- mllib
- benchmarks
- src
- main
- resources/META-INF/services
- scala/org/apache/spark
- mllib
- clustering
- feature
- fpm
- linalg/distributed
- ml
- classification
- clustering
- feature
- fpm
- image
- regression
- r
- source/image
- tree
- impl
- test/scala/org/apache/spark
- mllib
- clustering
- feature
- linalg
- ml
- classification
- feature
- fpm
- image
- regression
- source/image
- tree/impl
- util
- project
- python
- docs
- pyspark
- mllib
- ml
- sql
- streaming
- repl
- src/main/scala-2.11/org/apache/spark/repl
- resource-managers
- kubernetes
- core
- src
- main/scala/org/apache/spark
- deploy/k8s
- features
- bindings
- hadooputils
- security
- submit
- scheduler/cluster/k8s
- test/scala/org/apache/spark
- deploy/k8s
- features
- bindings
- submit
- scheduler/cluster/k8s
- docker/src/main/dockerfiles/spark
- bindings
- R
- python
- integration-tests
- dev
- src/test
- resources
- scala/org/apache/spark/deploy/k8s/integrationtest
- tests
- mesos
- src
- main/scala/org/apache/spark
- deploy/mesos
- scheduler/cluster/mesos
- test/scala/org/apache/spark/scheduler/cluster/mesos
- yarn
- src
- main/scala/org/apache/spark/deploy/yarn
- test/scala/org/apache/spark
- deploy/yarn
- network/yarn
- sbin
- sql
- catalyst
- benchmarks
- src
- main
- antlr4/org/apache/spark/sql/catalyst/parser
- java/org/apache/spark/sql/catalyst/expressions
- codegen
- scala/org/apache/spark/sql
- catalyst
- analysis
- catalog
- csv
- dsl
- encoders
- expressions
- aggregate
- codegen
- objects
- json
- optimizer
- parser
- planning
- plans
- logical
- physical
- rules
- util
- internal
- types
- util
- test
- java/org/apache/spark/sql/catalyst/expressions
- scala/org/apache/spark/sql
- catalyst
- analysis
- catalog
- csv
- encoders
- expressions
- aggregate
- codegen
- optimizer
- parser
- plans
- trees
- util
- util
- core
- benchmarks
- src
- main
- java/org/apache/spark/sql
- execution
- vectorized
- sources/v2
- reader/streaming
- writer/streaming
- vectorized
- scala/org/apache/spark/sql
- api/python
- execution
- aggregate
- arrow
- columnar
- command
- datasources
- csv
- json
- orc
- parquet
- v2
- exchange
- joins
- python
- streaming
- continuous
- sources
- state
- ui
- expressions
- internal
- streaming
- util
- test
- java/test/org/apache/spark/sql
- streaming
- resources
- sql-tests
- inputs
- subquery/in-subquery
- results
- subquery
- in-subquery
- negative-cases
- typeCoercion/native
- test-data
- scala/org/apache/spark/sql
- execution
- aggregate
- benchmark
- columnar
- compression
- datasources
- csv
- json
- orc
- parquet
- joins
- metric
- python
- streaming
- sources
- state
- vectorized
- internal
- sources
- v2
- streaming
- continuous
- sources
- test
- util
- hive-thriftserver
- src
- main
- java/org/apache/hive/service/server
- scala/org/apache/spark/sql/hive/thriftserver
- test/scala/org/apache/spark/sql/hive/thriftserver
- hive
- benchmarks
- 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/execution
- resources/regression-test-SPARK-8489
- scala/org/apache/spark/sql
- execution/benchmark
- hive
- client
- execution
- orc
- sources
- streaming
- src
- main/scala/org/apache/spark/streaming
- api/java
- dstream
- util
- test
- java/test/org/apache/spark/streaming
- scala/org/apache/spark/streaming
- tools
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
This file was deleted.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
17 | 17 | | |
18 | 18 | | |
19 | 19 | | |
20 | | - | |
| 20 | + | |
21 | 21 | | |
22 | 22 | | |
23 | 23 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
14 | 14 | | |
15 | 15 | | |
16 | 16 | | |
17 | | - | |
| 17 | + | |
18 | 18 | | |
19 | 19 | | |
20 | 20 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | 2 | | |
3 | | - | |
| 3 | + | |
4 | 4 | | |
5 | 5 | | |
6 | 6 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
28 | 28 | | |
29 | 29 | | |
30 | 30 | | |
31 | | - | |
32 | | - | |
33 | 31 | | |
| 32 | + | |
34 | 33 | | |
35 | 34 | | |
36 | 35 | | |
| |||
42 | 41 | | |
43 | 42 | | |
44 | 43 | | |
45 | | - | |
46 | | - | |
47 | | - | |
48 | 44 | | |
49 | 45 | | |
50 | 46 | | |
| |||
70 | 66 | | |
71 | 67 | | |
72 | 68 | | |
73 | | - | |
| 69 | + | |
| 70 | + | |
74 | 71 | | |
75 | 72 | | |
76 | 73 | | |
| |||
150 | 147 | | |
151 | 148 | | |
152 | 149 | | |
153 | | - | |
154 | 150 | | |
155 | 151 | | |
156 | 152 | | |
157 | 153 | | |
158 | 154 | | |
159 | 155 | | |
160 | 156 | | |
161 | | - | |
162 | 157 | | |
163 | 158 | | |
164 | 159 | | |
| |||
174 | 169 | | |
175 | 170 | | |
176 | 171 | | |
177 | | - | |
178 | 172 | | |
179 | 173 | | |
180 | 174 | | |
| |||
204 | 198 | | |
205 | 199 | | |
206 | 200 | | |
| 201 | + | |
| 202 | + | |
207 | 203 | | |
208 | 204 | | |
209 | 205 | | |
| |||
212 | 208 | | |
213 | 209 | | |
214 | 210 | | |
| 211 | + | |
215 | 212 | | |
216 | 213 | | |
217 | 214 | | |
| |||
271 | 268 | | |
272 | 269 | | |
273 | 270 | | |
| 271 | + | |
274 | 272 | | |
275 | 273 | | |
276 | 274 | | |
| |||
355 | 353 | | |
356 | 354 | | |
357 | 355 | | |
| 356 | + | |
358 | 357 | | |
359 | 358 | | |
360 | 359 | | |
| |||
409 | 408 | | |
410 | 409 | | |
411 | 410 | | |
412 | | - | |
413 | 411 | | |
414 | 412 | | |
415 | | - | |
416 | 413 | | |
417 | | - | |
418 | 414 | | |
419 | 415 | | |
420 | 416 | | |
421 | 417 | | |
422 | 418 | | |
423 | | - | |
424 | 419 | | |
425 | 420 | | |
426 | 421 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
226 | 226 | | |
227 | 227 | | |
228 | 228 | | |
229 | | - | |
| 229 | + | |
| 230 | + | |
| 231 | + | |
230 | 232 | | |
231 | 233 | | |
232 | 234 | | |
| |||
244 | 246 | | |
245 | 247 | | |
246 | 248 | | |
247 | | - | |
248 | | - | |
249 | | - | |
250 | | - | |
251 | | - | |
| 249 | + | |
| 250 | + | |
| 251 | + | |
| 252 | + | |
| 253 | + | |
| 254 | + | |
| 255 | + | |
| 256 | + | |
| 257 | + | |
| 258 | + | |
| 259 | + | |
| 260 | + | |
| 261 | + | |
| 262 | + | |
| 263 | + | |
| 264 | + | |
| 265 | + | |
| 266 | + | |
| 267 | + | |
| 268 | + | |
| 269 | + | |
| 270 | + | |
| 271 | + | |
| 272 | + | |
| 273 | + | |
| 274 | + | |
| 275 | + | |
252 | 276 | | |
253 | 277 | | |
254 | 278 | | |
| |||
497 | 521 | | |
498 | 522 | | |
499 | 523 | | |
500 | | - | |
501 | | - | |
502 | | - | |
503 | | - | |
504 | | - | |
505 | | - | |
506 | | - | |
507 | | - | |
508 | | - | |
509 | | - | |
510 | | - | |
511 | | - | |
512 | | - | |
513 | | - | |
514 | | - | |
515 | | - | |
516 | | - | |
517 | | - | |
518 | | - | |
519 | | - | |
520 | | - | |
521 | | - | |
522 | | - | |
523 | | - | |
524 | | - | |
525 | | - | |
526 | | - | |
527 | 524 | | |
528 | 525 | | |
529 | 526 | | |
| |||
933 | 930 | | |
934 | 931 | | |
935 | 932 | | |
936 | | - | |
937 | 933 | | |
938 | 934 | | |
939 | 935 | | |
| |||
944 | 940 | | |
945 | 941 | | |
946 | 942 | | |
947 | | - | |
948 | | - | |
949 | | - | |
950 | | - | |
951 | | - | |
952 | | - | |
953 | | - | |
954 | | - | |
955 | | - | |
956 | | - | |
957 | | - | |
958 | 943 | | |
959 | 944 | | |
960 | 945 | | |
| |||
2739 | 2724 | | |
2740 | 2725 | | |
2741 | 2726 | | |
2742 | | - | |
2743 | | - | |
2744 | | - | |
2745 | | - | |
2746 | | - | |
2747 | | - | |
2748 | | - | |
2749 | | - | |
2750 | | - | |
2751 | | - | |
2752 | | - | |
2753 | | - | |
2754 | 2727 | | |
2755 | 2728 | | |
2756 | 2729 | | |
| |||
2955 | 2928 | | |
2956 | 2929 | | |
2957 | 2930 | | |
| 2931 | + | |
| 2932 | + | |
| 2933 | + | |
2958 | 2934 | | |
2959 | 2935 | | |
2960 | 2936 | | |
| |||
2966 | 2942 | | |
2967 | 2943 | | |
2968 | 2944 | | |
2969 | | - | |
| 2945 | + | |
2970 | 2946 | | |
2971 | 2947 | | |
2972 | 2948 | | |
2973 | 2949 | | |
2974 | 2950 | | |
2975 | | - | |
| 2951 | + | |
2976 | 2952 | | |
2977 | 2953 | | |
2978 | 2954 | | |
| |||
2986 | 2962 | | |
2987 | 2963 | | |
2988 | 2964 | | |
| 2965 | + | |
| 2966 | + | |
| 2967 | + | |
| 2968 | + | |
| 2969 | + | |
| 2970 | + | |
| 2971 | + | |
2989 | 2972 | | |
2990 | 2973 | | |
| 2974 | + | |
| 2975 | + | |
| 2976 | + | |
2991 | 2977 | | |
2992 | 2978 | | |
2993 | 2979 | | |
| |||
3986 | 3972 | | |
3987 | 3973 | | |
3988 | 3974 | | |
3989 | | - | |
| 3975 | + | |
| 3976 | + | |
| 3977 | + | |
| 3978 | + | |
| 3979 | + | |
| 3980 | + | |
| 3981 | + | |
| 3982 | + | |
| 3983 | + | |
| 3984 | + | |
| 3985 | + | |
3990 | 3986 | | |
3991 | 3987 | | |
3992 | 3988 | | |
| |||
0 commit comments