我有一个事件数据流和另一个模式数据流。这些模式是由用户在运行时提供的,它们需要通过Kafka主题来实现。我需要使用flink cep在事件流上应用每个模式。当我事先不知道模式时,有没有办法从数据流中获取模式流?
o4tp2gmn1#
现在不可能。flinkcep只能处理静态应用的一种模式。有一张jira罚单:https://issues.apache.org/jira/browse/flink-7129 但无法判断此功能的预计到达时间。
1条答案
按热度按时间o4tp2gmn1#
现在不可能。flinkcep只能处理静态应用的一种模式。有一张jira罚单:https://issues.apache.org/jira/browse/flink-7129 但无法判断此功能的预计到达时间。