1.4 Apache Flink DataStream上是否有折叠式操作员

Question

我使用Apache Flink 1.4有这样的流设置 从datastream开始 然后键比 然后窗口 然后聚集

汇总操作的输出是聚集的对象因此，流的流目前的流是类型的singleOutputstreamoperator

我想做的接下来是相当于scala折叠的。有没有提供该功能的操作员。

谢谢

Answer 1

flink 1.4提供了类似于 foldLeft的 AggregateFunction。

聚合功能的API如下：初始（或开始）值在createAccumulator()方法中定义。累加器保持部分聚合的值。使用add()方法将值聚合到累加器中。最后，结果是通过getResult()方法从累加器中计算得出的。

foldLeft的区别在于，AggregateFunction能够通过其merge()方法合并其累加器（部分聚合物）。某些窗口类型（Session Windows）需要合并部分聚合的能力，并且对于某些优化。