Apache Flink：即使没有输入记录到达给定聚合窗口，也会基于键控状态在Flink中发出输出记录

Question

我正在尝试将Apache Flink用于IoT应用程序。我有一堆设备可以处于几种状态之一。当设备更改状态时，它会发出一条消息，其中包括事件时间戳和它更改到的状态。对于一个设备，可能如下所示：

{device_id:1,event_timestamp:9:01,state:STATE_1}

我的问题是：Flink只会为给定的device_id打开一个窗口，如果该窗口有一个事件。这意味着，如果设备超过5分钟没有改变状态，则不会有记录进入流，因此窗口不会打开。然而，我需要发出一条记录，说明设备在当前状态下花费了整整五分钟，这是基于键控状态下html" target="_blank">存储的内容。例如，Flink应该发出一条9:05-9:10的记录，该记录显示id为“1”的设备在“state_2”中度过了全部300秒。

是否有一种方法可以输出每个设备在五分钟聚合窗口中处于给定状态的时间量的记录，即使在这五分钟内状态没有改变，因此设备没有发送任何事件？如果没有，是否有任何变通方法可以用于获取应用程序所需的输出事件？

Answer 1

实现这一点的一种简单方法是使用ProcessFunction而不是窗口化。您可以保持任何对您的应用程序方便的键控状态，并使用计时器触发生成定期报告。