/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 vote123 views1 answer
Print fps in while loop python
Python
22 votes161 views6 answers
How to execute a cmd command in python
Python
9 votes107 views2 answers
Django import Q
Python
16 votes126 views3 answers
How to change the column order in pandas dataframe
Python
0 vote146 views1 answer
Last executed query in flask api
Python Flask
30 votes110 views6 answers
Python list to string
Python
0 vote111 views2 answers
Python if not none in one line
Python
2 votes117 views3 answers
WARNING: pip is configured with locations that require TLS/SSL, however the ssl module in Python is not available.
Python
0 vote126 views2 answers
Python youtube view bot
Python
0 vote117 views1 answer
Openpyxl add worksheet
Python