こんにちは。引き続きメッセージ処理のページを読み進めます。今回はTaskがメッセージを受信したときの動作について。 Message処理実装 ＝＝＝＝＝＝ ■Taskがメッセージ受信時に行う動作はローカルモードか、分散モードかで異なる1.ローカルモードにおいては…

こんにちは。では、StormのTuple処理の肝であるMessage Passingについて読んでいきます。 Message処理実装 ＝＝＝＝＝＝ 本ページでは、Emit/TransferされたTupleがどう動作するかを記述する。■Workerがメッセージの転送について統括する。 1.Workerにおいて…

前回に引き続き、Topologyのライフサイクルの章について読み進めます。 Topologyのライフサイクル Topologyモニタリング ＝＝＝＝＝ ■Nimbusは起動している間ずっとTopologyのモニタリングを行う。 1.Timerスレッドにて定期的にTopologyモニタリングタスクが…

少し間が空いてしまいましたが、続きになります。今回からはLifecycle of a topologyの章を確認していきます。 ・・・とりあえず書いてみましたが、ひたすらべた書きになっているため、 一通り読み終わったらわかりやすくまとめる必要がありそうですね（汗 T…

こんにちは。日本時間昨日未明にStormの0.8.0がリリースされました！ 性能の大きな向上、リソース配分の動的調整など、 追加機能が多いリリースですが、ライブラリもかなり更新されています。そのため、まずはライブラリを比較して差分を出してみることにし…