Spark scala RDD traversing

Question

Как я могу пройти через RDD, используя Spark scala. Я хочу распечатать каждое значение, присутствующее в Seq, с помощью связанного ключа

res1: org.apache.spark.rdd.RDD[(java.lang.String, Seq[java.lang.String])] = MapPartitionsRDD[6] at groupByKey at <console>:14 

Я пробовал использовать следующий код для него.

val ss=mapfile.map(x=>{ 
val key=x._1 
val value=x._2.sorted 
    var i=0 
while (i < value.length) { 
    (key,value(i)) 
    i += 1 
     } 
    }  
) 
ss.top(20).foreach(println) 

Answer 1

Я пытаюсь конвертировать ваши коды следующим образом:

val ss = mapfile.flatMap { 
    case (key, value) => value.sorted.map((key, _)) 
} 
ss.top(20).foreach(println) 

Является ли это то, что вы хотите?