2 つの異なるタイプのデータ ストリームがあり、1 つは気象データを提供し、もう 1 つは車両データを提供し、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
ありがとう！