scala - Flatten 加入 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))}