Flatten加入DStream

Question

我将一些 DStream 连接在一起，因此当前的 "datatype" 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))}