“Reduziert die Elemente dieser RDD mit dem angegebenen kommutativen und assoziativen Binärbetreiber” Code-Antworten

Reduziert die Elemente dieser RDD mit dem angegebenen kommutativen und assoziativen Binärbetreiber

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
"""