在RDD火花階

Question

執行字段的重排我有類型的RDD

RDD [（字符串，字符串，字符串）] //這是指格式 （設備名，日期的記錄，文字）

現在我需要執行（devicename，date）的groupbyKey。所以我想改造

RDD [（字符串，字符串，字符串）]到RDD [（字符串，字符串），字符串）]

，但我無法轉移。我試圖使用

val namedatekeyrecord=ip.map{ 

x => 

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

} 

但它不起作用，並拋出錯誤「缺少參數類型」。

你能幫我一下嗎？

感謝

Answer 1

我傻，

我忘了使用地圖的抽象：

val namedatekeyrecord=ip.map{ 

x => 

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

}