Привет, я просто искал еще один вопрос и задал этот вопрос. Вышеупомянутая проблема может быть выполнена с использованием нормальных преобразований.
val a=sc.parallelize(collection) a.map{case (x,y)=>(x.split (" ")(0)+" "+x.split(" ")(1))}.collect