Flink CEP의 시퀀스 일치 의미 체계

Question

Apache JIRA에 문제가 있습니다 : https://issues.apache.org/jira/browse/FLINK-3703. 일치하는 순서 후에 계속해야 매칭 알고리즘이 발견 된 곳은 정의 할 수 있으며, 행동의 세 가지 유형이 있습니다 :

• from first - (즉 현재 동작입니다)
• after first 미래 일치하는 모든 이벤트를 유지 계속이 -
• after last를 첫 번째 요소 후 계속 (제 1 매칭 이벤트를 제거하고, 두 번째 이벤트를 계속) -

,174 (효과적으로 일치 시퀀스의 모든 요소들을 폐기)의 마지막 요소 이후에 계속 우리는 일련의 사건이있는 경우 예를 들어

은 : 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.