/Python/Reduces the elements of this RDD using the specified commutative and associative binary operator

Reduces the elements of this RDD using the specified commutative and associative binary operator

from operator import add
sc.parallelize([1, 2, 3, 4, 5]).reduce(add)
# 15
sc.parallelize((2 for _ in range(10))).map(lambda x: 1).cache().reduce(add)
# 10
sc.parallelize([]).reduce(add)
"""
Traceback (most recent call last):
    ...
ValueError: Can not reduce() empty RDD
"""

Source: spark.apache.org

Similar codes

0 vote275 views1 answer
Form data postman don't work
Python
0 vote325 views1 answer
Python, read_csv from string
Python
0 vote295 views1 answer
How to add an symbol to a certain part of a list python
Python
14 votes272 views6 answers
Find last element in list python
Python
1 vote296 views1 answer
Bezier curve python
Python
0 vote290 views1 answer
Dataframeclient influxdb example
Python
0 vote274 views1 answer
File "main.py", line 11 if message.author == client.user: ^ IndentationError: expected an indented block
Python
6 votes324 views3 answers
Python compiler application in tkinter
Python
11 votes272 views3 answers
How to do pandas profiling
Python
0 vote281 views1 answer
Convert 2d string array to float python
Python