こんにちは、阪本です。 Apache FlinkでCEP（Complex Event Processing）の実現方法について、前回は時刻とグルーピングについて説明しました。 今回は、イベントのパターン定義を見てみましょう。これで、簡単なイベント処理ができるようになります。 パタ…

こんにちは、阪本です。 前回に引き続き、Apache FlinkでCEP（Complex Event Processing）の実現方法について紹介します。 イベントの時刻は何を基準にするか CEPをやるからには、イベントの時刻はとっても重要です。 Flinkでは、次の3つのいずれかの基準を…

こんにちは、阪本です。IoTやらデータ分析やらに関わる機会が増えて、大量のストリームデータに埋もれる（もとい、処理する＾＾；）ことが増えてきました。 しかも、関わっている業務的に、大概において、データ欠損は許されないという。。そんなストリーム…