我是 Flink CEP 的新手。对于我们的一个用例，我们需要为温度传感器输出实现流分析。如果温度持续升高 30 分钟，则需要向操作员发出警报。我浏览了模式 API，但找不到在模式中对此进行建模的方法？请建议一种使用模式检测此模式的可能方法
您可以考虑两种可能的选项。
第一种方法是使用 cep 中的迭代条件，该条件将检查当前事件的温度是否高于所有先前接受的事件。此处的文档中有一个IterativeCondition示例。 关键是调用ctx.getEventsForPattern，然后将当前事件与以前接受的事件进行比较。
第二种解决方案取决于确切的用例，但也许您可以使用滑动窗口在 30 分钟的窗口中收集元素，并根据数据收集的频率使用一些幻灯片。然后，根据时间戳对元素进行排序并验证窗口中是否有增长趋势应该非常容易。