Flink：仅在会话窗口结束时计算

Question

我有一个聚合函数，它计算WindowedStream中一系列事件的平均值。
这里的警告是，平均值需要在可能无序（或根本没有）到达的事件对上计算。

换句话说，我需要在计算之前对数据进行排序，因为序列很重要。

我可以用getResult API来实现这一点，但是这个函数在窗口中的每个事件上都被调用，这在性能方面没有意义。我也可以用flink cep来做这件事，但出于同样的原因，我想避免使用它。

理想情况下，当窗口关闭时，我只想在最后计算平均值（在这里我可以对数据进行一次排序）。

这有什么处理程序吗？我找到的最接近的东西是触发器，但是没有关闭窗口的方法

谢谢

编辑：
我最终使用了带有增量聚合的ProcessWindowFunction

ProcessWindowFunction可以与RedueFunction、Aggregate Function或FoldFunction相结合，以便在元素到达窗口时逐步聚合元素。当窗口关闭时，ProcessWindowFunction将提供聚合结果。这允许它增量计算窗口，同时可以访问ProcessWindowFunction的附加窗口元信息。

Answer 1

您可以使用ProcessWindowFunction而不是AggregateFunction，而无需增量聚合。触发窗口时将调用此函数，并将传递一个包含窗口内容的Iterable和一个可用于发出结果的收集器。

当调用ProcessWindowFunction时，您可以对内容进行排序，并产生您想要的任何输出。