HDFハンズオン 4: Stormでリアルタイム分析
実は、Stormトポロジはすでにデプロイされ、動いています。 今後のハンズオンではこの部分も深掘りしていきたいと思います。今回は何もする必要はありません。
詳細はhdf-tutorial-ja/stormをご参照ください。
本チュートリアルでは、Sliding Windowを利用して各キー毎の平均値を求めています。
- window size = count(10): 直近10個の要素を利用して平均値を求める
- sliding interval = count(3): 最新の3つが到着する度に、直近の10個で平均値を求める
よって、3つNiFiへとデータを登録する度に、平均値が更新されるような仕組みです。
