Flink CEPで "every"パターン演算子を使用する方法

Question

Esper CEPエンジンのイベントパターンには、Every演算子があり、everyキーワードで修飾された部分式がtrueまたはfalseと評価されたときにパターンの部分式を再起動する必要があることを示します。

According to this document、我々のようなさまざまな方法でevery演算子を使用することができます。

A -> B 
    every (A -> B) 
    every A -> B 
    A -> every B 
    every A -> every B 

私はFLINK CEP可能であるこれらのパターンのどの知りたいのですが？ Flinkでevery A -> Bを使用したいのですが、方法はわかりません。

そして、上記のパターンのうち、FlinkのデフォルトのCEPパターンはどれですか？ （Flink v1.1.4を使用）

Pattern<Event, ?> pattern = Pattern.begin("start").where(evt -> evt.getId() == 42) 
    .followedBy("end").where(evt -> evt.getName().equals("end")); 

ありがとうございます。

Answer 1

FLINKは、あなたがサブタイプを指定した場合、それはすべての反復

start.subtype(SubEvent.class).where(new SimpleCondition<SubEvent>() { 
    @Override 
    public boolean filter(SubEvent value) { 
     return ... // some condition 
    } 
}); 

のために呼び出されることを述べている。しかし、私の意見では、それはあなたが探しているものではありませんこれは、すべての使用方法についてのいくつかのdocumentationを提供します。しかし、軽量のSiddhi- Flink CEP libraryを見ると、Flinkでsiddhiクエリ言語を使用できるようになります