Iteration in Cogrouped zweiten Tupel CompactBuffer

Question

Ich habe zwei Schlüsselwert Pair rdd's A and B, Daten wie

A={(1,(1,john,CA)), 
(2,(2,steve,NY)), 
(3,(3,jonny,AL)), 
(4,(4,Evan,AK)), 
(5,(5,Tommy,AZ))} 

B={(1,(1,john,WA)), 
(1,(1,john,FL)), 
(1,(1,john,GA)), 
(2,(2,steve,NY)), 
(3,(3,jonny,AL)), 
(4,(4,Evan,AK)), 
(5,(5,Tommy,AZ))} 

Rdd B hat drei Werte für den Schlüssel 1 so während der Anwendung cogroup

c = A.cogroup(B).filter { x => ((x._2._1) != (x._2._2)) }.collect() we get 

c = {(1,CompactBuffer(1,john,CA),CompactBuffer(1,john,WA,1,john,FL,1,john,GA)} 

Sammeln zwei CompactBuffers sieht in zwei Variablen wie unten

d = c.map(tuple =>(tuple._2._1.mkString(""))) 
e = c.map(tuple =>(tuple._2._2.mkString(""))) 

Iterieren d und e wie unten

for(x <-d) 
{ 
    for(y <-e){ 

    println(x +" source and destination "+ y) 
    } 
} 

Erwartete Ausgabe

1,john,CA source and destination 1,john,WA 
1,john,CA source and destination 1,john,FL 
1,john,CA source and destination 1,john,GA 

Ausgang empfangen

1,john,CA source and destination 1,john,WA,1,john,FL,1,john,GA 

Was soll ich für Iterieren ändern die Second Tuple elements i.e Second Compactbuffer()

Bitte lassen Sie mich wissen, wenn Sie Zweifel oder Klärung in Frage haben.

Answer 1

Wie in den Kommentaren vorgeschlagen, konvertiert Ihr Array zu einem Array von einem Element. Alternativ können Sie Ihr faul Iterator bewerten, indem es in ein Array umzuwandeln und dann über sie iterieren:

c.foreach { x => 
    val arr1 = x._2._1.toArray 
    val arr2 = x._2._2.toArray 
    for (e1 <- arr1) { 
     for (e2 <- arr2) { 
      println (e1 + "-----------" + e2) 
     } 
    } 
} 

(1,john,CA)-----------(1,john,WA) 
(1,john,CA)-----------(1,john,FL) 
(1,john,CA)-----------(1,john,GA) 

Mit dem, was Sie geschrieben, Sie mkString mit einem flatMap Betrieb ersetzen können den Iterator zu bewerten:

d = c.flatMap(tuple =>tuple._2._1) 
e = c.flatMap(tuple =>tuple._2._2) 

Und dann fahren Sie mit Ihrer for Schleife fort.