Ordenar elementos de un RDD en Scala

por | Jun 25, 2018 | Big data, Scala, Spark | 0 Comentarios

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))

 

0 comentarios

Enviar un comentario

Tu dirección de correo electrónico no será publicada.