Spark scala RDD traversing

Question

어떻게 Spark scala를 사용하여 RDD를 따라 트래버스 할 수 있습니까? 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) 

당신이 원하는 무엇인가?