/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 vote189 views1 answer
Hh:mm to mins in python
Python
0 vote224 views1 answer
Django trigger when an instance od data is deleted from model
Python Django
0 vote170 views1 answer
Merge_sort
Python
19 votes175 views1 answer
Python string cut left
Python
0 vote202 views1 answer
Pands correlation matrix to dataframe
Python
1 vote178 views1 answer
Python display text in label on new line
Python
4 votes178 views1 answer
Text widget get tkinter
Python
2 votes127 views1 answer
Python array index
Python
0 vote193 views1 answer
How do you amke function in python
Python
17 votes192 views3 answers
How to split a string in python with multiple delimiters
Python