java - Apache Beam 中的 CEP 与 flink

Question

我们正在使用 Apache Beam 通过 Flink 处理来自各种来源的事件。我们处于需要使用 Flink 的 CEP 引擎来定义事件模式并引发警报的情况。为此，我无法在 beam 中找到任何包装 API。

请帮忙。

标签： javaapache-flinkapache-beamcomplex-event-processing

Answer 1

目前没有可用的 Beam CEP，有创建一个的任务，但我认为目前在这方面没有做太多工作。我认为如果你需要使用 CEP，你将不得不切换到 Flink 而不是 Beam。