インデントのずれがかなり多くて，本当にずれてるのか自分のviewer(MacのKitabu)でずれてるのか正直あまり自信がない
this.collector.emit(new Values(str),str);
-> this.collector.emit(new Values(str));
backtype、storm、topology、IRichBol
-> backtype.storm.topology.IRichBol
例2-2のインデントがおかしい
*/
public void execute(Tuple input) {Thread.sleep(1000);
-> Thread.sleep(2000);
InputDeclarerごとに2つ以上のソースを設定できる
-> 多分InputDeclarerいきなり出てくる
ランダムに選ばれたボルトすべてが同数受け取るよう
-> ランダムに選んでるのに同数？
back type
-> backtype
ソースのインデントがおかしい
if(values.size()>0){
String str = values.get(0).toString();
if(str.isEmpty())
boltIds.add(0);
else
boltIds.add(str.charAt(0) % numTasks);
}
return boltIds;ソースのインデントがおかしい
public void execute(Tuple input) {
...
for(String word : words){（Stormクライアントのインストール方法については付録Aを参照）とコラムの「Storm Clientのインストールについては、付録Aを参照すること。」がかぶっている
マップ上でclearを呼び出しても問題ない
-> nextTupleの中でclearを呼び出しても問題ない
"ツイッターからの解析に失敗した"と"twitter apiとの通信に失敗した["
-> twitterの表記が揺れている
ここではnextTupleメソッドをロックして、ackやfailメソッドを実行できないようにしている
-> どこでロックしているのか分からない．ソースには"LinkedBlockingQueue tweets = new LinkedBlockingQueue();"があるが定義しているだけで使ってない
Stormには、どのようなコンポーネント（スパウト、ボルト）からTopologyContextにアクセスできるという、興味深い機能がある
-> "どのようなコンポーネント（スパウト、ボルト）もTopologyContextにアクセスできるという"という感じ？
多分これソースはgithubに上がってないので実際のところはよくわからないけど，while (true)の1ループ毎にRedisクライアントをnewしているのはなんでなのか，よく分からない．
ソースのインデントがおかしい
public void prepare(Map conf, TopologyContext context, OutputCollector collector) {
this.collector = collector;
}インデントや"item ==null"などちょっとソースコードに統一感がない
多分下のコメントが間違っている．後インデントがおかしい
// アイテム・カテゴリー -> カウントする
HashMap<String, Integer> counter = new HashMap<String, Integer>();
// アイテム・カテゴリー -> カウントする
HashMap<String, Integer> pendingToSave = new HashMap<String, Integer>();異なるテストがWebサイトを閲覧するユーザーの行動をエミュレートするために行う
-> 異なるテストをWebサイトを閲覧するユーザーの行動をエミュレートするために行う
スパウトやボルトの作業を行うためのプロセスを行う
-> スパウトやボルトの作業を行うための外部プロセスを起動する
idがあるところが、処理するtupleのIDになる。
-> idが、処理するtupleのIDになる。
tupleをストリームの送信するのは
-> tupleをストリームに送信するのは
まず気づいてほしい重要なポイントとして、これがBaseBatchBoltだとわかること、がある。ということは、受信したtupleに対してexecuteメソッドが実行されるが、新規tupleは切り出されない
-> BaseBatchBoltはここで多分初めて出てくる.
finishBatchのインデントがおかしい
「コーディネーターボルト」（coordinator bolts）は
-> 「コミッターボルト」（committer bolts）
後インデントがおかしい
// カーサーを動かす
-> カーソル？cursorをそのままの読みで訳した感じがする
別のtupleを受け取っているので、8ではなく、さらに4をカウントする。
-> この4ってどっから出てきたの…