使用不需要所有Flink环境的flink-cep模式匹配

Question

如标题所示:是否可以只使用flink模式匹配而不使用整个flink环境？

Answer 1

Flink CEP库不打算在Flink之外使用，因此不可能开箱即用。

然而，底层自动机不依赖于任何Flink代码，因此您可以自己提取它。有趣的类将是NFA和NFACompiler。

Answer 2

我猜您是在问这个问题，因为您试图解决的问题可能有一些内存需求，或者您希望在模式类中执行一些更改。

1. 如果您有内存问题，您可以继续使用Esper或Siddhi CEP引擎，因为它们没有像Flink那样的依赖项。
2. 对于第二种情况，如@Dawid所指出的，您希望对模式文件进行一些更改或查看查询处理是如何工作的，那么您应该使用NFA类。这是因为CEP模式匹配的基本方法是将查询树解析为非确定性有限自动机，它在叶子节点接收输入流，并使用每个级别的操作符来关联流值和筛选值，并将其发送到上层操作符进行过滤等等。最终值将在此树的根处接收。

特别是，如果您要与低级别和基本的CEP引擎交互，我发现SASE引擎很有帮助。SASE文件的链接是https://arxiv.org/ftp/cs/papers/0612/0612128.pdf

您可以查看NFA文件的代码，以便更好地了解https://github.com/haopeng/sase/tree/master/src/edu/umass/cs/sase/query。

如果您有疑问，请告诉我。