扁平化 List 类型的 DStream
Flatten DStream of List type
问题
嘿，我有一个类型为 List[A] 的 DStream，将此 DStream 转换为类型 A 的最佳方法是什么？
为了帮助说明我的目标，我想要
List(A, A, A, ....), List(A, A, ...), List(A, A, A, ...), ...
成为
A, A, A, A, A, ...
基本上它在概念上与展平操作非常相似。谢谢！
更新：
我想我明白了，一个简单的 flatMap 应该可以做到。无论如何谢谢！
以防万一有人想要答案。
如果 x 是 List[A] 的某个 DStream，则在 x 上应用平面映射，其中转换函数只是 returns 列表，会将这些列表展平为 A.
的 DStream
val x: DStream[List[A]] = ...
val y: DStream[A] = x.flatmap(k => k)
问题
嘿，我有一个类型为 List[A] 的 DStream，将此 DStream 转换为类型 A 的最佳方法是什么？
为了帮助说明我的目标，我想要
List(A, A, A, ....), List(A, A, ...), List(A, A, A, ...), ...
成为
A, A, A, A, A, ...
基本上它在概念上与展平操作非常相似。谢谢！
更新：
我想我明白了，一个简单的 flatMap 应该可以做到。无论如何谢谢！
以防万一有人想要答案。 如果 x 是 List[A] 的某个 DStream，则在 x 上应用平面映射，其中转换函数只是 returns 列表，会将这些列表展平为 A.
的 DStream
val x: DStream[List[A]] = ...
val y: DStream[A] = x.flatmap(k => k)