“Renvoyez un RDD créé en fusionnant tous les éléments de chaque partition dans une liste.” Réponses codées

Renvoyez un RDD créé en fusionnant tous les éléments de chaque partition dans une liste.

rdd = sc.parallelize([1, 2, 3, 4], 2)
sorted(rdd.glom().collect())
# [[1, 2], [3, 4]]