問題タブ [flink-cep]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
apache-flink - Apache Flink CEP は、RMQSource をリッスンする前に入力データ ストリームを初期化します
Flink 1.2 CEP を使用して、デバイスから欠落しているハート ビート イベントを検出しています。RabbitMQ ソースからハート ビート イベントを読み取り、次のパターンを使用して、シリアル番号でキーが設定されたデバイスのハート ビートの欠落をタイムアウト関数で検出します。
このパターン ストリームは、少なくとも 1 つのハートビートがデバイスから送信される場合に機能します。しかし、アプリケーションの起動後にハートビートが 1 つも開始されていないデバイスの欠落ハートビートを検出するユースケースも処理する必要があります。
このためには、すべてのデバイスの init Heart Beat イベントで入力ハートビート ストリームを初期化する必要があります。ストリームを初期化すると、最初のハートビートを受信していないデバイスも処理され、タイムアウトしてアラートが発生します。
RMQSource 関数からリッスンする前であっても、すべてのデバイスの初期化ハート ビート データでデータ ストリームを初期化するにはどうすればよいですか?