kimutansk https://blog.hatena.ne.jp/kimutansk/ 夢とガラクタの集積場 https://kimutansk.hatenablog.com/ Storm こんにちは。では、StormのTuple処理の肝であるMessage Passingについて読んでいきます。 Message処理実装 ＝＝＝＝＝＝ 本ページでは、Emit/TransferされたTupleがどう動作するかを記述する。■Workerがメッセージの転送について統括する。 1.Workerにおいて、設定値：task.refresh.poll.secs秒経過するかZooKeeper上のアサイン情報が更新するたびにrefresh-connectionsメソッドが呼び出される。 本メソッドは他Workerとの接続維持と、「task -> worker」のマッピングを維持する。 (https… 190 <iframe src="https://hatenablog-parts.com/embed?url=https%3A%2F%2Fkimutansk.hatenablog.com%2Fentry%2F20120619%2F1340058279" title="Stormの内部実装を解説する資料確認してます（その５ - 夢とガラクタの集積場" class="embed-card embed-blogcard" scrolling="no" frameborder="0" style="display: block; width: 100%; height: 190px; max-width: 500px; margin: 10px 0px;"></iframe> Hatena Blog https://hatena.blog 2012-06-19 07:24:39 rich https://kimutansk.hatenablog.com/entry/20120619/1340058279 1.0 100%