는 RDD 스파크 스칼라

Question

의 필드의 재 배열을 수행하여 I 형의 RDD가

RDD의 [(문자열, 문자열, 문자열)] //이 형식 (장치 이름, 날짜의 기록을 의미 텍스트)

이제 groupbyKey of (devicename, date)을 수행해야합니다. 그래서 [(문자열, 문자열) 문자열)]

RDD하는

RDD의 [(문자열, 문자열, 문자열)] 변환 생각하지만 전송 드릴 수 없습니다. 나는

val namedatekeyrecord=ip.map{ 

x => 

(a,b,c)=>((a,b),c) 

} 

을 사용하려했지만 그것은 작동 및 오류 "실종 매개 변수 유형을"가 발생하지 않습니다.

내 접근 방식을 도와 줄 수 있습니까?

val namedatekeyrecord=ip.map{ 

x => 

((x._1,x._2),x._3) 

} 

: 나는지도 추상화를 사용하는 것을 잊었다

감사

Answer 1

바보 나

,