“Retorne um RDD criado coalescando todos os elementos dentro de cada partição em uma lista.” Respostas de código

Retorne um RDD criado coalescando todos os elementos dentro de cada partição em uma lista.

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