spark RDD 변환 질문있습니다ㅠㅠㅠ

Question

val rdd1 &#61; sc.parallelize(Seq((1,2),(1,3),(1,4),(2,3),(2,4),(3,4)))을 통하여 rdd1을 생성해주었습니다.저는 각 정점별로 그래프의 차수를 구해주기 위하여rdd1을 기존 (1,2) (1,3) (1,4) (2,3) (2,4) (3,4)에다가 역순인 (2,1) (3,1) (4,1) (3,2) (4,2) (4,3)을 추가해주어 각 key별로 value의 개수를 통하여 차수를 구하고자 합니다.rdd1의 요소중 (x,y)에다가 (y,x)를 추가해주는 방법을 어떻게 해야할까요?? ㅠㅠㅠ

spark RDD 변환 질문있습니다ㅠㅠㅠ

0개의 답변

Q&A 목록