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을 제공합니다, 당신이 찾고있는 것이 아니다. 그러나 Flink에서 siddhi 쿼리 언어를 사용할 수있는 가벼운 무게의 Siddhi- Flink CEP library을 사용하면