假设我有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)
谢谢!