Спарк РДД Строка Совокупные

Question

Я уровне -3 новичок в Scala/Спарк, у меня есть и RDD[String,String] содержащий п слово в строке как:

id1, cat fish 
id1, eat red 
id2, blue Dog 

И я хотел бы получить RDD[String,String] как:

id1, cat fish eat red 
id2, blue Dog 

до сих пор я уже попробовал groupByKey

val rdd2 = rdd1.groupByKey()

Благодарим вас за любые советы.

Answer 1

rdd1.reduceByKey((s1, s2) => s1 + " " + s2)