2017-12-19 20 views
0

이벤트의 데이터 스트림과 패턴의 다른 데이터 스트림이 있습니다. 패턴은 런타임에 사용자가 제공하며 카프카 (Kafka) 주제를 통해 올 필요가 있습니다. Flink-CEP를 사용하여 각 패턴을 이벤트 스트림에 적용해야합니다. 미리 패턴을 모를 때 DataStream에서 PatternStream을 가져 오는 방법이 있습니까?Apache Flink : 소스에서 다른 데이터 스트림으로 패턴을 적용하는 방법은 무엇입니까?

답변

1

현재로서는 불가능합니다. FlinkCEP는 정적으로 적용된 패턴 하나만 처리 할 수 ​​있습니다. JIRA 티켓 (https://issues.apache.org/jira/browse/FLINK-7129)이 있지만 ETA에이 기능을 알릴 수 없습니다.

+0

시간 창을 사용하여이 논리를 복제 할 수 있습니까? – wittyameta