Diary/2014-4-17の変更点

• 追加された行はこのように表示されます。
• 削除された行はこのように表示されます。

!Storm
Stormで遊んでみようかな，と．

まずは，チュートリアルを読んでみます．
http://storm.incubator.apache.org/documentation/Tutorial.html
...が，要領がつかめなかったので，
[EclipseでStormの開発環境を作る|http://tjun.org/blog/2011/11/storm_eclipse/]からのブログの内容にもお世話になりつつ

::準備
* [Stormをlocalmodeで実行する|http://tjun.org/blog/2011/11/storm_localmode/]を参考に．要はサンプルをEclipseにインポートして必要なJARを追加すればよい．
** [storm-starter|https://github.com/nathanmarz/storm-starter]をgit cloneする
*** jvm以下をEclipseにインポート，適当にパッケージをあわせる
** [Setting up a development environment|http://storm.incubator.apache.org/documentation/Setting-up-development-environment.html]からStorm releaseをダウンロード
** [Commons Collections|https://commons.apache.org/proper/commons-collections/]が必要だったのでダウンロード．3.2.1の方．
* これでEclipseでコンパイルが通るようになった．
* Jarを作ろうとすると，たしかにWarningがでる...が無視
* 実行してみる
 storm jar storm-test.jar storm.starter.ExclamationTopology
* たしかに，ずらーっと文字が表示されて，環境は用意できたっぽい

::で？
ExclamationTopology.javaの中の
ExclamationBoltクラスで定義されている，
    @Override
    public void execute(Tuple tuple) {
      _collector.emit(tuple, new Values(tuple.getString(0) + "!!!"));
      _collector.ack(tuple);
    }
というところで!!!をつけてるんだろうなーというのはわかるけど...という感じ．

::さて
他のサンプルがぱっと動かせてないので，それらも動かせば，もう少し感触つかめるのかな．
うーん，いろいろと，たとえば，
* Spark
* Twitter SummingBird
あたりか？どっちもScalaなんだなあ．

調べてるとOSSじゃないとこで，
* [クラウドサービスプラットフォーム Cosminexus：uCosminexus Stream Data Platform|http://www.hitachi.co.jp/Prod/comp/soft1/cosminexus/sdp/]
とかもあるのね．

あらためて，川島さんの[学術的に見たストリームデータ処理（私見）|http://www.slideshare.net/HideyukiKawashima/2013-0628okachimachiupload]をみなおしたりも．