すべてのFlink環境なしでflink-cepパターンマッチングを使用する

Question

タイトルと同じです：他のフリンク環境全体を使用せずに単にフリンクパターンマッチングを使用できますか？

Answer 1

Flink CEPライブラリは、Flinkの外で使用することを意図していないため、そのまま使用することはできません。

しかし、基本となるオートマトンはFlinkコードに依存しないため、自分で抽出することができます。面白いクラスはNFAとNFACompilerです。

Answer 2

あなたが解決しようとしている問題がメモリ要件を持っているか、パターンクラスでいくつかの変更を実行したいので、この質問をしているようです。

1. あなたには、Flinkのような依存関係がないため、EsperまたはSiddhi CEPエンジンを使用することができます。

2. 2番目のケースでは、パターンファイルに何らかの変更を加えたり、クエリ処理の仕組みを見たい場合は、NFAクラスを@Dawidが指摘したとおりに使用する必要があります。これは、基本的にCEPパターンのマッチングは、リーフノードで入力ストリームを受け取り、各レベルの演算子を使用してストリームとフィルタ値の値を関連付ける非決定性有限オートマトンとしてクエリツリーを解析し、それを上位レベルの演算子に送信するフィルタリングなどがあります。最終値はこのツリーのルートで受信されます。

特に、低レベルの基本的なCEPエンジンとやりとりする場合は、SASEエンジンが役立ちました。 SASE紙のためのリンクは https://arxiv.org/ftp/cs/papers/0612/0612128.pdf

であるあなたは、より理解https://github.com/haopeng/sase/tree/master/src/edu/umass/cs/sase/query

を取得するためにNFAファイルのコードを見ることができますが、いくつかのクエリ

を持っているなら、私に知らせてください。