✅ Перевірена відповідь на це питання доступна нижче. Наші рішення, перевірені спільнотою, допомагають краще зрозуміти матеріал.
print(acc.value)? acc = sc.accumulator(0)
rdd = sc.parallelize([1,2,3])
def f(x):
acc.add(1) return x r = rdd.map(f).cache()
r.count()
r.collect()
print(acc.value)