/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

21 votes168 views4 answers
Get list input from user in python
Python
0 vote161 views1 answer
Get list of users django
Python
0 vote157 views1 answer
Python word encode asci
Python
1 vote168 views1 answer
Keras ensure equal class representation during traingin
Python
120 votes166 views6 answers
Getting Input in Python
Python
0 vote159 views1 answer
Validate delete inline formset django
Python
1 vote162 views1 answer
Message on member joining discord.py
Python
3 votes153 views2 answers
What day i s it
Python
0 vote164 views1 answer
Bar Plot Seaborn with No Error Bars
Python
4 votes153 views5 answers
Python read xml
Python