“Devolver un RDD creado al fusionar todos los elementos dentro de cada partición en una lista.” Código de respuesta

Devolver un RDD creado al fusionar todos los elementos dentro de cada partición en una lista.

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