小编Jam*_*mie的帖子

Flink CEP:对于不同类型的事件,使用哪种方法加入数据流?

假设我有2种不同类型的数据流,一种提供天气数据,另一种提供车辆数据,我想使用Flink对数据进行复杂的事件处理。

Flink 1.3.x 中哪种方法是正确的使用方法?我看到了不同的方法,如 Union、Connect、Window Join。基本上我只是想尝试一个简单的 CEP,如下所示:

IF weather is wet AND vehicle speed > 60 
WITHIN the last 10 seconds
THEN raise alert
Run Code Online (Sandbox Code Playgroud)

谢谢!

apache-flink flink-cep

3
推荐指数
1
解决办法
780
查看次数

标签 统计

apache-flink ×1

flink-cep ×1