将集合流平面映射到其元素流

问题描述

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

我对flatMap函数的语法有问题

val stream = DataStream[Seq[Event]]

stream.flatMap(???)

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

推荐答案

我建议您查看Flink附带的示例，例如wordcount application：

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)

documentation在Scala(和Java)中也有一些有用的代码片段。

这篇关于将集合流平面映射到其元素流的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！