拼合加入DSTREAM

Question

我加入了一些DSTREAM的在一起，使DSTREAM當前「數據類型」看起來像這樣（鍵和值）：

DStream[(Long,((DateTime,Int),((Int,Double),Double)))] 

但我想：

DStream[(Long,DateTime,Int,Int,Double,Double)] 

或

DStream[(Long,(DateTime,Int,Int,Double,Double)] 

是有，我可以申請我的DSTREAM改造，否則我怎麼能做到這一點的任何功能？

在此先感謝！

Answer 1

你可能尋找地圖功能：

stream.map {case (lng, ((dt, i1),((i2, d1),d2))) => (lng,dt,i1,i2,d1,d2)} 

或

stream.map {case (lng, ((dt, i1),((i2, d1),d2))) => (lng,(dt,i1,i2,d1,d2))}