列表型扁平DStream

Question

问题

嘿，我有一个带有List[A]类型的DStream，把这个DStream转换成A的最好方法是什么？

为了说明我的目标，我想

List(A, A, A, ....), List(A, A, ...), List(A, A, A, ...), ...

成为

A, A, A, A, A, ...

基本上，它在概念上非常类似于扁平操作。谢谢!

更新:我想我明白了，一个简单的flatMap就可以做到这一点。不管怎样，谢谢你！

Answer 1

以防有人想知道答案。如果x是一些DStream of ListA，然后在x上应用一个平面映射，其中转换函数只是返回列表，则将这些列表压平成A的DStream。

val x: DStream[List[A]] = ... val y: DStream[A] = x.flatmap(k => k)