我们使用apachebeam通过flink处理来自不同来源的事件。我们需要使用flink的cep引擎来定义事件模式并发出警报。我在beam中找不到任何用于此的 Package 器api。请帮忙。
a1o7rhls1#
目前没有梁cep可用，有任务创建一个，但我不认为目前有很多工作要做。我认为如果你需要使用cep，你将不得不切换到flink而不是beam。
1条答案
按热度按时间a1o7rhls1#
目前没有梁cep可用，有任务创建一个，但我不认为目前有很多工作要做。我认为如果你需要使用cep，你将不得不切换到flink而不是beam。