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