使用 flink 的 apache beam 中的 CEP

Question

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

请帮忙。

Answer 1

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