flink 解题思路

课程题目

现在我需要使用flink流式计算解决一个问题

大致情景就是 有好几天的数据，每条数据自带时间戳，间隔一分钟一条，数据记录了设备的状态，现在需要计算出24小时内设备状态连续2小时为某状态的设备信息。

有大佬能提供解题思路吗，感谢。