Ordenar elementos de un RDD en Scala

Ordenar elementos por clave – sortByKey()scala_logo

Nos devuelve un RDD ordenado por clave

// Ejemplo ascendente
val rdd = sc.parallelize(List(("tren", 1), ("avion", 2), ("barco", 4), ("barco", 3)))
rdd.sortByKey(true).collect()
res: Array[(String, Int)] = Array((avion,2), (barco,4), (barco,3), (tren,1))
// Ejemplo descendente
val rdd = sc.parallelize(List(("tren", 1), ("avion", 2), ("barco", 4), ("barco", 3)))
rdd.sortByKey(false).collect()
res: Array[(String, Int)] = Array((tren,1), (barco,4), (barco,3), (avion,2))

 

Otros artículos que pueden ser de interés:

Autor: Diego Calvo