acro-engineer https://blog.hatena.ne.jp/acro-engineer/ Taste of Tech Topics https://acro-engineer.hatenablog.com/ Flink こんにちは、阪本です。 Apache FlinkでCEP（Complex Event Processing）の実現方法について、前回は時刻とグルーピングについて説明しました。 今回は、イベントのパターン定義を見てみましょう。これで、簡単なイベント処理ができるようになります。 パターンを定義する ここでは、「15秒以内に温度が30℃を2回以上超える」を表すパターンを定義します。 パターンは、CEPクラスのpatternメソッドで次のように定義します。 なお、keyedStreamは、前回作成したKeyedStream<Map<String, Object>, String>型のストリームです。 … 190 <iframe src="https://hatenablog-parts.com/embed?url=https%3A%2F%2Facro-engineer.hatenablog.com%2Fentry%2F2017%2F06%2F08%2F120000" title="Apache FlinkでCEPを実現　～パターン指定～ - Taste of Tech Topics" class="embed-card embed-blogcard" scrolling="no" frameborder="0" style="display: block; width: 100%; height: 190px; max-width: 500px; margin: 10px 0px;"></iframe> https://cdn-ak.f.st-hatena.com/images/fotolife/a/acro-engineer/20170317/20170317094950.png Hatena Blog https://hatena.blog 2017-06-08 12:00:00 rich https://acro-engineer.hatenablog.com/entry/2017/06/08/120000 1.0 100%