我有一个事件的数据流，以及另一个模式的数据流。用户在运行时提供模式，他们需要通过Kafka主题。我需要使用Flink-CEP在事件流上应用每个模式。当我事先不知道模式时，有没有办法从DataStream获取PatternStream？
目前不可能。 FlinkCEP只能处理静态应用的一个模式。有一个JIRA票：https://issues.apache.org/jira/browse/FLINK-7129但不能告诉ETA这个功能。