在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) 

}