/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

8 votes326 views6 answers
Python int to binary
Python
23 votes431 views6 answers
Flask post
Python Flask
4 votes305 views1 answer
Orderd set in python
Python
0 vote352 views1 answer
To run python script in terminal i want to type python insted of python3
Python
0 vote326 views1 answer
Create a date value array in python
Python
1 vote307 views1 answer
Boolean python meaning for idiots
Python
22 votes332 views6 answers
Pyinstaller windows
Python
0 vote421 views1 answer
How to compress image field in django?
Python
4 votes317 views3 answers
Formatting strings in python
Python
2 votes360 views2 answers
Mean deviation python
Python