いくつかの動的テンプレートに従って、大量のイベントを処理するためにFlink CEPを使用する予定です。システムは事象の連鎖を認識しなければならない（条件やグループ分けを伴う複雑な連鎖など）。テンプレートはユーザーによって作成されます。つまり、コードに触れることなく複雑なテンプレートを作成する必要があります。この問題を解決するためにApache Flinkを使用することは可能ですか？ Filnkはダイナミックテンプレートをサポートしていますか？FlinkとDynamicテンプレートの認識
現在、FlinkのCEPライブラリは、この種の動的ルール適合をサポートしていません。しかし、実装が不可能な根本的な理由はありません。
実際、変更はかなり単純です。現時点では、ワークフローは次のとおりです。ユーザーがイベントパターンを指定します。このパターンはパターンを表すNFAに変換されます（これはクライアント側で発生します）。その後、NFAはCEP演算子に渡され、CEP演算子は直列化されてクラスタに送られます。クラスタでは、CEP演算子とNFAがデシリアライズされ、イベントの処理が開始されます。
1つの入力チャネルでイベントを受け取り、他の入力チャネルパターンで受け取るコフラットマップ演算子が追加できます。新しく受信したパターンごとに、既存のNFAを更新するか（この機能が欠落している）、新しいNFAをコンパイルするかのいずれかが行われます。後者の場合、格納されたすべてのNFAに着信イベントが適用されます。
こうして、パターンを動的に更新できるCEP演算子を実現することができます。