Ordenar elementos por clave – sortByKey()
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))
0 comentarios