/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 vote365 views1 answer
Django 2.2 disable cache settings.STATIC_URL
Python
27 votes357 views6 answers
Remove column from dataframe
Python
7 votes372 views1 answer
Float to percentage python
Python
0 vote359 views3 answers
Split credit card number python
Python
68 votes400 views6 answers
Create directory in python
Python
1 vote338 views1 answer
Numpy isinstance
Python
0 vote375 views1 answer
Selenium python tkinter
Python
0 vote360 views1 answer
Merge multile dict
Python
8 votes374 views3 answers
Python clone object
Python
9 votes337 views4 answers
Pca python
Python