Флаттен присоединился к 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))}