我有一个事件数据流和另一个模式数据流。这些模式由用户在运行时提供,它们需要通过 Kafka 主题来。我需要使用 Flink-CEP 在事件流上应用每个模式。当我事先不知道模式时,有没有办法从 DataStream 中获取 PatternStream?
问问题
91 次
1 回答
1
目前是不可能的。FlinkCEP 只能处理一个静态应用的 Pattern。有一张 JIRA 票:https ://issues.apache.org/jira/browse/FLINK-7129但不能告诉 ETA 这个功能。
于 2017-12-19T09:52:45.410 回答