!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]をみなおしたりも.