我们使用apachebeam通过flink处理来自不同来源的事件。我们需要使用flink的cep引擎来定义事件模式并发出警报。我在beam中找不到任何用于此的 Package 器api。
请帮忙。