こんにちは。 では、さっそく実際のコードを書いてみましょう。今回の範囲は「２．１ フォーム」です。 「実際にClojureでどうやって記述するか？」の章で、多分この辺が中途半端だったので途中からわけわからくなっていました。 そのため、地道に。 1.フォ…

最近Stormのコードを読んでいるのですが、Clojureの基本文法が曖昧なために 結局深いところは読み解けないという状態に陥っている今日この頃です。というわけで、プログラミングClojureを使って 実際にClojureのコードを書いて、理解を深めることにします・…

こんにちは。 なんか１年以上忘れ去っていましたが、 最近StormのClojureコードを読むことが増えてきましたので、とりあえずゆるゆると再開してみます。 1.まず重要なのはClojureのコードです これはStormを扱う上でいうまでもない内容になりますね。 ・・・…

こんにちは。#stormjp のタグでStormの雑多な情報まとめその９です。 とりあえず、2013/02までの内容はこの回で収まりそうなペースです。91.DisruptorQueueから情報を取得するのはシングルスレッドとなる。 そのため、Worker数を増やすことでボトルネックが…

こんにちは。#stormjp のタグでStormの雑多な情報まとめその７です。 段々、終わりが見えてきたような感はありますｗ○81.Stormクラスタ自体のアップデートは起動しっぱなしでは無理。 安全確実を期すなら下記のフロー。 １．Topology全部落とす ２．Storm-Ni…

こんにちは。#stormjp のタグでStormの雑多な情報まとめその７です。 お、思ったより手ごわいｗ 71.単一のBoltからイベントの内容を見て違うBoltに分岐させたい場合、 違うStreamに書きこめば分岐が可能。Stormの開発者もその方式を推奨している。 尚、受信…

こんにちは。#stormjp のタグでStormの雑多な情報まとめその６です。 とりあえず、二桁いかない程度で終わらせる方向で。55.Storm-UIでのNimbusの表示情報の大部分はZookeeperから取得している。 （残りはNimbusのローカルファイル） そのため、Zookeeperが…

こんにちは。#stormjp のタグでStormの雑多な情報まとめその５です。 いや、思ったより呟いていた量多かったんですねｗ○36.StreamGroupingのうち、FieldGroupingはキーのハッシュ値で配分先が決まるContext Hashing方式。 ShuffleGroupingはラウンドロビン方…

こんにちは。#stormjp のタグでStormの雑多な情報まとめその４です。 とりあえず最後までやりきる方針で。○28.StormのNimbus、UI、Supervisorにはデフォルトでは終了コマンドはない。 Storm-Installer等一段階ラッピングするか、killで落とすしかない。▽29.T…

こんにちは。#stormjp のタグでStormの雑多な情報まとめその３です。 段々前置きとかが思いつかなくなってきましたが、とりあえず入ります＾＾；○19.StormとKestrelを組み合わせることで『Kestrelから取得したメッセージをStormで処理完了したことを保証する…

こんにちは。#stormjp のタグでStormの雑多な情報まとめその２です。 ちなみに呟きの過去から情報は追っていっていますが、呟いた後に判明した情報も 芋づる式に記述しています。 そのため、単に過去わかった情報だけではない・・・という構成になっています…

こんにちは。全く前回から繋がりがなくて微妙ですが、やっていたことを。 SSDのクラウドサービス、DigitalOceanを試してみました。・・・え？全く脈絡ないって？ 1.そもそも、何故使おうと思ったの？ 元々は１か月ほど前にFacebookで流れていた下記の画像が…