/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 vote162 views1 answer
How can i remove random symbols in a dataframe in Pandas
Python
0 vote174 views1 answer
What is the use of extend in python
Python
0 vote273 views1 answer
Printing multiple input in python
Python
0 vote134 views1 answer
How do I know which animation is playing animation player
Python
0 vote173 views1 answer
Separating a relational plot based on a sixth variable | seaborn relational plot
Python
0 vote133 views1 answer
Keras callbacks
Python
0 vote189 views1 answer
How to take long input in python
Python
0 vote183 views1 answer
Python 2.7 get user input
Python
0 vote197 views1 answer
How to write user input to a file in python
Python
0 vote182 views1 answer
How to call the tkinter insert command from another class
Python