用窗口和状态进行截面聚合

Question

我正在寻找一种在窗口上实现聚合/折叠函数的方法，该函数也具有状态。我了解如何在窗口上汇总以及如何使用密钥/全球状态 - 但不是两者。

要清楚，当我说一个带状态的窗口时 - 我的意思是每次更改窗口/移动。

例如：我想计算每5分钟按事件类型键入的事件数量。但是，除了事件类型(这是窗口键(之外，该事件还有一些ID字段 - 我只想计算每个ID一次 - 因此我需要保存我已经在该窗口中计算的所有ID的状态。

有没有一种简单的方法在flink中进行？

Answer 1

flink具有丰富的功能，这将使您访问给定键的所有窗口中的全局状态。如果您需要每个窗口状态，请参见[Flink-5929]，它将是Flink 1.3的一部分。