Apache Flink广播流中基于应用窗口的规则

Question

我在Apache Flink的BroadcastStream中有一组规则。我可以在事件流中应用新规则。但是我无法弄清楚如果规则>]

rule 1> alert when count of event a is greater than 5 in a window of 5 mins
rule 2> alert when count of event a is greater than 4 in a window of 15 mins
我是老手。我无法弄清楚。

我在Apache Flink的BroadcastStream中有一组规则。我可以在事件流中应用新规则。但是我无法弄清楚如果我的规则像...

Answer 1

基于flink-sql或flink-cep的应用程序将无法执行此操作，因为这些库只能处理在编译作业时定义的规则。您可能需要为每个新规则开始一个新工作，而这可能不符合您的要求。