Diary/2014-4-17

Storm

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

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

準備

• Stormをlocalmodeで実行するを参考に．要はサンプルをEclipseにインポートして必要なJARを追加すればよい．
  • storm-starterをgit cloneする
    • jvm以下をEclipseにインポート，適当にパッケージをあわせる
  • Setting up a development environmentからStorm releaseをダウンロード
  • 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

とかもあるのね．

あらためて，川島さんの学術的に見たストリームデータ処理（私見）をみなおしたりも．