将集合的流平面映射为其元素的流

Question

我有一个事件序列流，并希望将其平面映射到一个事件流。

我对flatMap函数的语法有问题

val stream = DataStream[Seq[Event]]
stream.flatMap(???)

如有任何帮助，将不胜感激

Answer 1

我建议您看看Flink附带的示例，比如这个wordcount应用程序：

val counts: DataStream[(String, Int)] = text
// split up the lines in pairs (2-tuples) containing: (word,1)
.flatMap(_.toLowerCase.split("\W+"))
.filter(_.nonEmpty)
.map((_, 1))
// group by the tuple field "0" and sum up tuple field "1"
.keyBy(0)
.sum(1)

文档中还有一些有用的scala(和java(代码片段。