Taste of Tech Topics

Acroquest Technology株式会社のエンジニアが書く技術ブログ

Flink

Apache FlinkでCEPを実現 ~パターン指定~

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

Apache FlinkでCEPを実現 ~イベント時刻とグルーピング~

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

Apache Flink の耐障害性はどんなもの? ~Exactly once の振る舞い~

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