apacheflink:如何将模式从一个源应用到另一个数据流?

f0brbegy  于 2021-06-25  发布在  Flink
关注(0)|答案(1)|浏览(276)

我有一个事件数据流和另一个模式数据流。这些模式是由用户在运行时提供的,它们需要通过Kafka主题来实现。我需要使用flink cep在事件流上应用每个模式。当我事先不知道模式时,有没有办法从数据流中获取模式流?

o4tp2gmn

o4tp2gmn1#

现在不可能。flinkcep只能处理静态应用的一种模式。有一张jira罚单:https://issues.apache.org/jira/browse/flink-7129 但无法判断此功能的预计到达时间。

相关问题