Flink CEPのシーケンス一致のセマンティクス

Question

Apache JIRAに問題があります：https://issues.apache.org/jira/browse/FLINK-3703。

after first（つまり、現在の動作です）今後の試合のために、すべてのイベントを保ち続ける -

• from first：それは、一致シーケンスが発見されたと行動の3種類があります後にマッチングアルゴリズムを継続すべき場所を定義することができます -
• after lastの最初の要素の後に続けて（最初の一致するイベントを削除し、第2のイベントを継続） -

（有効一致シーケンスのすべての要素を廃棄する）最後の要素の後に続けます私たちは一連のイベントがある場合たとえば

は、：A、B、Cとパターンfirst -> secondを、私たちは次の結果が得られます：

• from first - A -> B、A -> C、B -> C
• after first - A -> B、B -> C
• after last - A -> B

さて問題は、他のタスクに実装されているすべてのことをコメントで閉鎖されています

これは、内の継続のための数量詞の実装、スキップまで、次のといくつかの追加の問題を含む他の問題によって覆われていましたループパターン。

Flink CEPライブラリの現在のAPIを使用して、定義された種類の動作を実装する方法を教えてもらえますか？

Answer 1

私は私の質問に対する答えを見つけました。この情報を共有したいと思います。一致するシーケンスが見つかった後のマッチングアルゴリズムの動作をAfterMatchSkipStrategyで定義できます。しかし、バージョン1.4以降でしか動作しません。さて、リリースを待っています。

詳細はこちらhttps://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/libs/cep.html#after-match-skip-strategyです。