apache-flink - AggregateFunction 中合并方法的含义

Question

我正在尝试理解 Flink 中描述的 AggregateFunction here .总共有四种方法，

1. 创建累加器
2. 添加
3. 获取结果
4. 合并

据我了解，

createAccumulator 方法在第一个元素进入新窗口时调用，新创建的实例将被进一步使用

add 方法被调用以根据定义减少结果，这使用在 createAccumulator 方法中创建的实例

getResult 方法在窗口关闭时调用并返回可用结果

我对以上方法的理解是否正确？最后，merge 方法的用例是什么以及何时使用/调用它？可用的定义here我不清楚。

Answer 1

合并两个窗口时调用merge 方法。这适用于 session 窗口，每当两个 session 因弥合 session 之间差距的事件的到来而合并为一个时， session 窗口就会合并。发生这种情况时，将通过调用 merge 合并两个 session 的最新汇总结果。