0

私はApache flinkに完全に慣れていません。手を汚そうとしているだけです。次のシナリオがあります。

  1. イベントのデータストリーム
  2. イベントのデータストリーム
  3. ルールのデータストリーム
  4. ruleID に基づいてこれら 2 つのデータストリームを結合

今私は tuple3 のようなデータストリームを持っています<ruleId, Rule, Event>。これらのルールは、イベントで実行したい SQL クエリです。

私は動的テーブルと Flink SQL の概念を経験していました。さらに処理する方法がわかりません。誰かがこれで私を助けてくれますか?

4

1 に答える 1