“Wendet eine Funktion auf alle Elemente dieser RDD an.” Code-Antworten

Wendet eine Funktion auf alle Elemente dieser RDD an.

def f(x): print(x)
sc.parallelize([1, 2, 3, 4, 5]).foreach(f)