일부 동적 템플릿에 따라 많은 양의 이벤트를 처리하기 위해 Flink CEP를 사용할 계획입니다. 시스템은 이벤트 체인을 인식해야합니다 (조건 및 그룹화가있는 복잡한 체인). 템플릿은 사용자가 만듭니다. 즉, 코드를 건드리지 않고 복잡한 템플릿을 만들어야합니다. 이 문제를 해결하기 위해 Apache Flink를 사용할 수 있습니까? Filnk는 동적 템플릿을 지원합니까?플립 크 및 동적 템플릿 인식
현재 Flink의 CEP 라이브러리는 이러한 종류의 동적 규칙 적용을 지원하지 않습니다. 그러나 구현이 불가능한 근본적인 이유는 없습니다.
실제로 변경 사항은 간단합니다. 현재 워크 플로는 다음과 같습니다. 사용자가 이벤트 패턴을 지정합니다. 이 패턴은 패턴을 나타내는 NFA로 변환됩니다 (클라이언트 측에서 발생 함). 그런 다음 NFA가 직렬화되어 클러스터로 전달되는 CEP 운영자에게 제공됩니다. 클러스터에서 CEP 연산자와 NFA는 deserialize 된 다음 이벤트 처리를 시작합니다.
하나의 입력 채널에서 이벤트를 수신하고 다른 입력 채널 패턴을 수신하는 공동 평면지도 연산자가 추가 될 수 있습니다. 새로 수신 된 각 패턴에 대해 하나는 기존 NFA를 업데이트하거나 (이 기능이 누락 됨) 새 NFA를 컴파일합니다. 후자의 경우 들어오는 이벤트를 저장된 모든 NFA에 적용합니다.
그런 식으로 패턴을 동적으로 업데이트 할 수있는 CEP 연산자를 구현할 수 있습니다.