0
回答
请问spark groupBykey后的数据怎么恢复到一个key对应一个value的形式?
终于搞明白,存储TCO原来是这样算的>>>   

请问spark groupByKey后的结果,怎么又恢复到一个key对应一个value的形式,这种形式的数据用来存入数据库用。例如groupBykey后的数据如下:
(280001,CompactBuffer(06:30, 05:00, 05:30, 00:00, 06:33))
(280001,CompactBuffer(04:30))
(280001,CompactBuffer(05:00, 06:33))

恢复后的数据结果如下:

(280001,06:30)
(280001,05:00)
(280001,05:30)
(280001,00:00)
(280001,06:33)
(280001,04:30)
(280001,05:00)
(280001,06:33)

<无标签>
举报
闵开慧
发帖于1个月前 0回/12阅
顶部