Wie Tupel in Tupel von Tupeln in scala reduzieren

Question

ich mit Reihen von Typ

(a,(b,c,d)) 
(a,(e,f,g)) 

Ich versuche es mit Schlüssel so zu reduzieren RDD haben, dass es Reihen vom Typ

(a,(b,c,d),(e,f,g)). 

ergibt Aber Ich bekomme einen Fehler bei der Verwendung dieses:

val redcd = mapd.reduceByKey((_,_)) 

Wie mache ich das?

Answer 1

Wenn Sie RDD haben als

scala> mapd.foreach(println) 
(a,(b,c,d)) 
(a,(e,f,g)) 
(b,(b,c,d)) 

Dann

tun

val redcd = mapd.groupBy(_._1).mapValues(x => x.map(_._2).toList) 

würde Ihnen

scala> redcd.foreach(println) 
(b,List((b,c,d))) 
(a,List((b,c,d), (e,f,g))) 

Nun, wenn Sie es wollen, in das Format in Frage erklärt können Sie

tun

val redcd = mapd.groupBy(_._1).mapValues(x => x.map(_._2).toList.mkString(", ")) 

die

scala> redcd.foreach(println) 
(a,(b,c,d), (e,f,g)) 
(b,(b,c,d)) 

erzeugen würde ich hoffe, die Antwort hilfreich