스칼라 스파크의 경우 For 루프 문제

Question

rdds 필드를 키별로 비교하고 일치하지 않는 배열 필드를 채우려 고하지만 for 루프를 사용할 수없는 경우.

루프에 대한 1 차 현장 점검을 위해 노력하고 주석되는 코드 아래

하지만 난 그 루프에 대한 작업을하는 방법을 모든 필드 비교

에게 어떤 생각을 충당하기 위해 루프를 사용 싶었던 모든 필드 그래서, b가 동일하지 않은 경우 채울 수 있습니까?

---a is of String type 
---b is of Array[String] type 
---c is of Array[String] type 

var i=0 
val joinedrdd = rdds1.join(rdds2) 
val res= joinedrdd.map { 
    case (a, (b, c)) => (
    //for (i <- 0 until (b.length - 1)){ 
     if (b(i).toString != c(i).toString) 
     {(a, b(i), c(i))} 
    //} 
    ) 
} 

Answer 1

내가 모르는 다른 더 효율적인 방법이있을 수 있습니다. 그러나 zip 내부 모두 Array과 map이 다를 경우 해당 값을 찾은 다음 해당 값이 바뀌면 값을 바꿉니다. 난 그냥 here 무엇을했는지

jrdd.map { 
    case (id, (xs, ys)) => (id, xs.zip(ys).map { 
    case (x, y) if x == y => x // if x = y return x or y 
    case _ => "random" // if they differ then return random 
    }) 
} 

당신이 볼 수/시험.