/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 vote307 views1 answer
Image resolution extracting python
Python
0 vote282 views2 answers
Module 'matplotlib' has no attribute 'xlabel'
Python
0 vote274 views1 answer
Newtorkx remove node
Python
0 vote277 views1 answer
HTTPSConnectionPool(host='files.pythonhosted.org', port=443): Read timed out
Python
0 vote270 views1 answer
Pandas groupby and show specific column
Python
2 votes296 views1 answer
Python how to get the last element in a list
Python
0 vote326 views1 answer
Or operator in django queryset
Python Django
-1 vote275 views1 answer
EJERCICIOS DE FOR Y WHILE en python
Python
0 vote311 views1 answer
Double char python
Python
1 vote292 views1 answer
Scatter plot of a dataframe in python
Python