- 분할지도하는 getKey을 내가 텍스트 파일 느릅 나무가 등등

Question

에는 다음이 포함

A>B,C,D 
B>A,C,D,E 
C>A,B,D,E 
D>A,B,C,E 
E>B,C,D 

나는 다음과 같은 얻기 위해 스파크 - 스칼라 스크립트를 작성하려합니다

: 각 왼쪽의 경우 (회원은, 우리는 모든 권리 구성원을 제공합니다.)

(A,B) 
(A,C) 
(A,D) 
(B,A) 
(B,C) 
(B,D) 
(B,E) 
... 

나는지도를 통해 이동 내 결과를 새로운 맵을 공급하기 위해 키를 얻기 위해 시도했지만 작동하지 않았다. 나는 내 요구에 어떤 답을 찾을 수 없기 때문에이 - 스칼라 불꽃이 같은 기본적인 코드를 작성할 수 있습니다 궁금

import scala.io.Source 

// Loading file 
val file = sc.textFile("friends.txt") 

// MAP 
// A;B 
// A;C 
// ... 

var associations_persons_friends:Map[Char,Char] = Map() 

var lines = file.map(line=>line.split(">")) 

for (line <- lines) 
{ 
    val person = line.key 

    for (friend <- line.value.split(",")) 
    { 
     associations_persons_friends += (person -> friend) 
    } 
} 

associations_persons_friends.collect() 

val rdd = sc.parallelize(associations_persons_friends) 
rdd.foreach(println) 


// GROUP 
// For each possible pair, all associated values 
// AB;B-C-D-A-C-D-E 


// REDUCE 
// For each pair we keep occurences >= 2 
// AB;C-D 

: 여기

(자세한 의사 코드 같은) 내 코드입니다 인터넷. 도움 주셔서 감사합니다.

Answer 1

당신은 당신은 내가 대답은 작동