我有一个事件数据流和另一个模式数据流。这些模式是由用户在运行时提供的,它们需要通过Kafka主题来提供。我需要使用Flink-CEP将每个模式应用于事件流。当我事先不知道模式时,有没有办法从DataStream中获取PatternStream?
发布于 2017-12-19 17:52:45
目前是不可能的。FlinkCEP只能处理静态应用的一种模式。有一张JIRA的罚单:https://issues.apache.org/jira/browse/FLINK-7129,但不能告诉ETA这个特性。
https://stackoverflow.com/questions/47883408
复制相似问题