RDD의 각 행에 서로를 곱하는 방법은 무엇입니까?

Question

나는 유사한 RDD,

CELL-ID | COUNT 
-------------- 
abcd  10 
DEF  20 
ghi  15 

내가

CELL-ID-1 | CELL-ID-2 | PRODUCT 
-------------- 
abcd  DEF   200 
abcd  ghi   150 
DEF  abcd   200 
DEF  ghi   300 
... 
.... 

어떻게

가이 작업을 수행 할 수 있습니다와 함께 RDD를 얻을 필요가 있나요? 나는 t1과 t2이 튜플을 (전체 "기록")를 나타냅니다 직교 제품을 사용하는 연결했지만 당신은 할 수 있습니다 출력

val result = orginalRDD.cartesian(orginalRDD).collect { 
    case ((t1: _,Int), (t2: _,Int)) if t1 != t2 => t1 * t2 
} 

Answer 1

를 가져올 수 없습니다 :

val result = orginalRDD.cartesian(orginalRDD).collect { 
    case (t1: (String ,Int), t2: (String ,Int)) if t1 != t2 => (t1._1, t2._1, t1._2 * t2._2) 
} 

또는를, 당신은 동일한 작업을 수행하지만, 더 그들을 파괴하기 위해 패턴 매칭을 사용할 수 있습니다

val result = orginalRDD.cartesian(orginalRDD).collect { 
    case (t1@(s1 ,i1), t2@(s2, i2)) if t1 != t2 => (s1, s2, i1 * i2) 
} 

귀하의 솔루션 모습을 한 번에 두 가지 작업을 시도하는 것과 같습니다 ...