Commit 0ecba8a
committed
Merge branch 'master' of https://github.com/apache/spark into SPARK-29126-cogroup-udf-usage-guide
# Conflicts:
# python/pyspark/sql/cogroup.pyFile tree
904 files changed
+15979
-6200
lines changed- R
- pkg
- R
- inst/worker
- tests/fulltests
- common/unsafe/src
- main/java/org/apache/spark/unsafe/types
- test
- java/org/apache/spark/unsafe/types
- scala/org/apache/spark/unsafe/types
- core
- benchmarks
- src
- main
- java/org/apache/spark
- memory
- unsafe/map
- resources/org/apache/spark/ui/static
- scala/org/apache/spark
- api
- java
- python
- r
- broadcast
- deploy
- client
- history
- master
- ui
- worker
- ui
- executor
- input
- internal
- io
- memory
- metrics
- sink
- network/netty
- partial
- rdd
- scheduler
- cluster
- local
- serializer
- status
- api/v1
- storage
- ui
- util
- collection
- logging
- random
- test
- java/org/apache/spark
- unsafe/map
- util/collection/unsafe/sort
- scala/org/apache/spark
- broadcast
- deploy
- client
- history
- master
- ui
- rest
- worker
- ui
- executor
- input
- io
- memory
- metrics
- network/netty
- rdd
- resource
- rpc
- netty
- scheduler
- security
- serializer
- shuffle/sort
- status
- storage
- ui
- util
- collection
- unsafe/sort
- dev
- deps
- docs
- _data
- examples
- src/main/scala/org/apache/spark/examples
- graphx
- mllib
- ml
- sql
- hive
- streaming
- streaming
- clickstream
- external
- avro
- benchmarks
- src/test/scala/org/apache/spark/sql/avro
- kafka-0-10-sql
- src
- main/scala/org/apache/spark/sql/kafka010
- test/scala/org/apache/spark/sql/kafka010
- kafka-0-10-token-provider/src
- main/scala/org/apache/spark/kafka010
- test/scala/org/apache/spark/kafka010
- kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010
- mocks
- kinesis-asl/src
- main/scala/org/apache/spark
- examples/streaming
- streaming/kinesis
- test/scala/org/apache/spark/streaming/kinesis
- graphx/src
- main/scala/org/apache/spark/graphx
- impl
- lib
- util
- collection
- test/scala/org/apache/spark/graphx
- lib
- licenses-binary
- mllib-local/src
- main/scala/org/apache/spark/ml/linalg
- test/scala/org/apache/spark/ml/linalg
- mllib
- benchmarks
- src
- main/scala/org/apache/spark
- mllib
- api/python
- clustering
- evaluation
- linalg
- distributed
- random
- util
- ml
- feature
- recommendation
- regression
- tree/impl
- util
- test/scala/org/apache/spark
- mllib
- classification
- feature
- linalg
- distributed
- random
- rdd
- recommendation
- regression
- tree
- util
- ml
- classification
- feature
- regression
- tree/impl
- util
- project
- python
- pyspark
- ml
- tests
- sql
- tests
- repl/src
- main/scala/org/apache/spark/repl
- test/scala/org/apache/spark/repl
- resource-managers
- kubernetes
- core/src
- main/scala/org/apache/spark
- deploy/k8s
- scheduler/cluster/k8s
- test/scala/org/apache/spark/deploy/k8s
- submit
- docker/src/main/dockerfiles/spark
- bindings
- R
- python
- mesos/src
- main/scala/org/apache/spark
- deploy/mesos
- ui
- executor
- scheduler/cluster/mesos
- test/scala/org/apache/spark
- deploy/rest/mesos
- scheduler/cluster/mesos
- yarn/src
- main/scala/org/apache/spark
- deploy/yarn
- scheduler/cluster
- test/scala/org/apache/spark
- deploy/yarn
- scheduler/cluster
- sql
- catalyst
- benchmarks
- src
- main
- antlr4/org/apache/spark/sql/catalyst/parser
- java/org/apache/spark/sql/connector/catalog
- scala/org/apache/spark/sql
- catalyst
- analysis
- catalog
- expressions
- aggregate
- optimizer
- parser
- plans/logical
- sql
- trees
- util
- connector/catalog
- internal
- test/scala/org/apache/spark/sql
- catalyst
- analysis
- catalog
- csv
- encoders
- expressions
- aggregate
- codegen
- optimizer
- parser
- plans
- trees
- util
- connector/catalog
- types
- core
- benchmarks
- src
- main/scala/org/apache/spark/sql
- catalyst/analysis
- execution
- columnar
- command
- datasources
- jdbc
- v2
- exchange
- python
- streaming
- continuous
- window
- internal
- test
- java/test/org/apache/spark/sql
- resources/sql-tests
- inputs
- postgreSQL
- results
- postgreSQL
- scala/org/apache/spark/sql
- connector
- execution
- aggregate
- benchmark
- columnar
- compression
- command
- datasources
- csv
- json
- orc
- parquet
- python
- streaming
- sources
- state
- vectorized
- jdbc
- sources
- streaming
- continuous
- test
- util
- hive-thriftserver/src
- main/scala/org/apache/spark/sql/hive/thriftserver
- 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
- test/scala/org/apache/spark/sql/hive
- client
- execution
- test
- streaming
- src
- main/scala/org/apache/spark/streaming
- api
- java
- python
- dstream
- receiver
- scheduler
- ui
- util
- test/scala/org/apache/spark/streaming
- rdd
- scheduler
- util
- tools
- src/main/scala/org/apache/spark/tools
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
904 files changed
+15979
-6200
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
243 | 243 | | |
244 | 244 | | |
245 | 245 | | |
246 | | - | |
| 246 | + | |
247 | 247 | | |
248 | 248 | | |
249 | 249 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
218 | 218 | | |
219 | 219 | | |
220 | 220 | | |
| 221 | + | |
221 | 222 | | |
222 | 223 | | |
223 | 224 | | |
224 | 225 | | |
225 | 226 | | |
226 | 227 | | |
227 | | - | |
| 228 | + | |
228 | 229 | | |
229 | 230 | | |
230 | 231 | | |
| |||
253 | 254 | | |
254 | 255 | | |
255 | 256 | | |
| 257 | + | |
256 | 258 | | |
257 | 259 | | |
258 | 260 | | |
259 | 261 | | |
260 | 262 | | |
261 | 263 | | |
| 264 | + | |
262 | 265 | | |
263 | 266 | | |
264 | 267 | | |
265 | 268 | | |
266 | 269 | | |
267 | 270 | | |
268 | 271 | | |
| 272 | + | |
269 | 273 | | |
270 | 274 | | |
271 | 275 | | |
| |||
278 | 282 | | |
279 | 283 | | |
280 | 284 | | |
| 285 | + | |
| 286 | + | |
| 287 | + | |
| 288 | + | |
| 289 | + | |
| 290 | + | |
| 291 | + | |
| 292 | + | |
| 293 | + | |
| 294 | + | |
| 295 | + | |
| 296 | + | |
| 297 | + | |
| 298 | + | |
| 299 | + | |
281 | 300 | | |
282 | 301 | | |
283 | 302 | | |
| |||
292 | 311 | | |
293 | 312 | | |
294 | 313 | | |
| 314 | + | |
| 315 | + | |
295 | 316 | | |
296 | 317 | | |
297 | 318 | | |
| 319 | + | |
298 | 320 | | |
| 321 | + | |
299 | 322 | | |
300 | 323 | | |
| 324 | + | |
| 325 | + | |
301 | 326 | | |
302 | 327 | | |
| 328 | + | |
303 | 329 | | |
304 | 330 | | |
| 331 | + | |
305 | 332 | | |
306 | 333 | | |
307 | 334 | | |
| |||
313 | 340 | | |
314 | 341 | | |
315 | 342 | | |
| 343 | + | |
| 344 | + | |
316 | 345 | | |
317 | 346 | | |
318 | 347 | | |
| |||
328 | 357 | | |
329 | 358 | | |
330 | 359 | | |
| 360 | + | |
331 | 361 | | |
332 | 362 | | |
333 | 363 | | |
| |||
343 | 373 | | |
344 | 374 | | |
345 | 375 | | |
346 | | - | |
347 | | - | |
348 | | - | |
349 | | - | |
350 | | - | |
351 | 376 | | |
352 | 377 | | |
353 | 378 | | |
| |||
371 | 396 | | |
372 | 397 | | |
373 | 398 | | |
| 399 | + | |
| 400 | + | |
374 | 401 | | |
| 402 | + | |
| 403 | + | |
375 | 404 | | |
| 405 | + | |
376 | 406 | | |
377 | 407 | | |
378 | 408 | | |
379 | 409 | | |
| 410 | + | |
380 | 411 | | |
381 | 412 | | |
382 | 413 | | |
383 | 414 | | |
384 | 415 | | |
385 | 416 | | |
| 417 | + | |
386 | 418 | | |
387 | 419 | | |
388 | 420 | | |
| |||
401 | 433 | | |
402 | 434 | | |
403 | 435 | | |
| 436 | + | |
404 | 437 | | |
405 | 438 | | |
406 | 439 | | |
407 | 440 | | |
408 | 441 | | |
409 | 442 | | |
410 | 443 | | |
| 444 | + | |
411 | 445 | | |
412 | 446 | | |
413 | 447 | | |
| |||
424 | 458 | | |
425 | 459 | | |
426 | 460 | | |
| 461 | + | |
427 | 462 | | |
428 | 463 | | |
429 | 464 | | |
| |||
449 | 484 | | |
450 | 485 | | |
451 | 486 | | |
| 487 | + | |
452 | 488 | | |
453 | 489 | | |
454 | 490 | | |
| |||
486 | 522 | | |
487 | 523 | | |
488 | 524 | | |
| 525 | + | |
489 | 526 | | |
490 | 527 | | |
491 | 528 | | |
| |||
516 | 553 | | |
517 | 554 | | |
518 | 555 | | |
| 556 | + | |
519 | 557 | | |
520 | 558 | | |
521 | 559 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
65 | 65 | | |
66 | 66 | | |
67 | 67 | | |
68 | | - | |
69 | | - | |
| 68 | + | |
| 69 | + | |
70 | 70 | | |
71 | 71 | | |
72 | 72 | | |
| |||
661 | 661 | | |
662 | 662 | | |
663 | 663 | | |
| 664 | + | |
| 665 | + | |
| 666 | + | |
664 | 667 | | |
665 | 668 | | |
666 | 669 | | |
| |||
1140 | 1143 | | |
1141 | 1144 | | |
1142 | 1145 | | |
| 1146 | + | |
| 1147 | + | |
| 1148 | + | |
| 1149 | + | |
| 1150 | + | |
| 1151 | + | |
1143 | 1152 | | |
1144 | 1153 | | |
1145 | 1154 | | |
| 1155 | + | |
| 1156 | + | |
| 1157 | + | |
| 1158 | + | |
| 1159 | + | |
| 1160 | + | |
1146 | 1161 | | |
1147 | 1162 | | |
1148 | 1163 | | |
| 1164 | + | |
| 1165 | + | |
| 1166 | + | |
1149 | 1167 | | |
1150 | 1168 | | |
1151 | 1169 | | |
1152 | 1170 | | |
1153 | 1171 | | |
1154 | 1172 | | |
| 1173 | + | |
| 1174 | + | |
| 1175 | + | |
1155 | 1176 | | |
1156 | 1177 | | |
1157 | 1178 | | |
| |||
1359 | 1380 | | |
1360 | 1381 | | |
1361 | 1382 | | |
| 1383 | + | |
| 1384 | + | |
| 1385 | + | |
| 1386 | + | |
| 1387 | + | |
| 1388 | + | |
1362 | 1389 | | |
1363 | 1390 | | |
1364 | 1391 | | |
1365 | 1392 | | |
1366 | 1393 | | |
1367 | 1394 | | |
| 1395 | + | |
| 1396 | + | |
| 1397 | + | |
| 1398 | + | |
| 1399 | + | |
| 1400 | + | |
| 1401 | + | |
| 1402 | + | |
| 1403 | + | |
| 1404 | + | |
| 1405 | + | |
| 1406 | + | |
| 1407 | + | |
| 1408 | + | |
| 1409 | + | |
| 1410 | + | |
| 1411 | + | |
| 1412 | + | |
| 1413 | + | |
| 1414 | + | |
| 1415 | + | |
| 1416 | + | |
| 1417 | + | |
| 1418 | + | |
| 1419 | + | |
| 1420 | + | |
| 1421 | + | |
| 1422 | + | |
| 1423 | + | |
| 1424 | + | |
| 1425 | + | |
| 1426 | + | |
| 1427 | + | |
| 1428 | + | |
| 1429 | + | |
| 1430 | + | |
| 1431 | + | |
| 1432 | + | |
| 1433 | + | |
| 1434 | + | |
| 1435 | + | |
| 1436 | + | |
| 1437 | + | |
| 1438 | + | |
| 1439 | + | |
| 1440 | + | |
| 1441 | + | |
| 1442 | + | |
| 1443 | + | |
| 1444 | + | |
| 1445 | + | |
| 1446 | + | |
| 1447 | + | |
| 1448 | + | |
| 1449 | + | |
| 1450 | + | |
| 1451 | + | |
| 1452 | + | |
| 1453 | + | |
| 1454 | + | |
| 1455 | + | |
| 1456 | + | |
| 1457 | + | |
| 1458 | + | |
| 1459 | + | |
| 1460 | + | |
| 1461 | + | |
| 1462 | + | |
| 1463 | + | |
| 1464 | + | |
| 1465 | + | |
| 1466 | + | |
| 1467 | + | |
| 1468 | + | |
| 1469 | + | |
| 1470 | + | |
| 1471 | + | |
| 1472 | + | |
| 1473 | + | |
| 1474 | + | |
| 1475 | + | |
| 1476 | + | |
| 1477 | + | |
| 1478 | + | |
| 1479 | + | |
| 1480 | + | |
| 1481 | + | |
| 1482 | + | |
| 1483 | + | |
| 1484 | + | |
| 1485 | + | |
| 1486 | + | |
| 1487 | + | |
| 1488 | + | |
| 1489 | + | |
| 1490 | + | |
| 1491 | + | |
| 1492 | + | |
| 1493 | + | |
| 1494 | + | |
| 1495 | + | |
| 1496 | + | |
| 1497 | + | |
| 1498 | + | |
| 1499 | + | |
| 1500 | + | |
| 1501 | + | |
| 1502 | + | |
| 1503 | + | |
| 1504 | + | |
| 1505 | + | |
| 1506 | + | |
| 1507 | + | |
| 1508 | + | |
| 1509 | + | |
| 1510 | + | |
| 1511 | + | |
| 1512 | + | |
| 1513 | + | |
| 1514 | + | |
| 1515 | + | |
| 1516 | + | |
| 1517 | + | |
0 commit comments