package?storm.blueprints.chapter1.v1;

import?backtype.storm.task.OutputCollector;
import?backtype.storm.task.TopologyContext;
import?backtype.storm.topology.OutputFieldsDeclarer;
import?backtype.storm.topology.base.baseRichBolt;
import?backtype.storm.tuple.Tuple;
import?java.util.ArrayList;
import?java.util.Collections;
import?java.util.HashMap;
import?java.util.List;
import?java.util.Map;

public?class?ReportBolt?extends?baseRichBolt?{

????private?HashMap?counts?=?null;

????public?void?prepare（Map?config?TopologyContext?context?OutputCollector?collector）?{
????????this.counts?=?new?HashMap（）;
????}

????public?void?execute（Tuple?tuple）?{
????????String?word?=?tuple.getStringByField（“word“）;
????????Long?count?=?tuple.getLongByField（“count“）;
????????this.counts.put（word?count）;
????}

????public?void?declareOutputFields（OutputFieldsDeclarer?declarer）?{
????????//?this?bolt?does?not?emit?anything
????}

????@Override
????public?void?cleanup（）?{
????????System.out.println（“---?FINAL?COUNTS?---“）;
????????List?keys?=?new?ArrayList（）;
????????keys.addAll（this.counts.keySet（））;
????????Collections.sort（keys）;
????????for?（String?key?:?keys）?{
????????????System.out.println（key?+?“?:?“?+?this.counts.get（key））;
????????}
????????System.out.println（“--------------“）;
????}
}

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----
?????目錄???????????0??2014-03-24?17:47??8294OS_Code\
?????目錄???????????0??2014-03-24?16:48??8294OS_Code\Chapter01\
?????文件????????1348??2014-03-24?16:48??8294OS_Code\Chapter01\.classpath
?????文件?????????661??2014-03-24?16:48??8294OS_Code\Chapter01\.project
?????目錄???????????0??2014-03-24?16:48??8294OS_Code\Chapter01\.settings\
?????文件?????????120??2014-03-24?16:48??8294OS_Code\Chapter01\.settings\org.eclipse.core.resources.prefs
?????文件?????????238??2014-03-24?16:48??8294OS_Code\Chapter01\.settings\org.eclipse.jdt.core.prefs
?????文件??????????86??2014-03-24?16:48??8294OS_Code\Chapter01\.settings\org.eclipse.m2e.core.prefs
?????文件????????5494??2014-03-24?16:48??8294OS_Code\Chapter01\Chapter1?（1）.iml
?????文件????????2155??2014-03-24?16:48??8294OS_Code\Chapter01\pom.xml
?????目錄???????????0??2014-03-24?16:48??8294OS_Code\Chapter01\src\
?????目錄???????????0??2014-03-24?16:48??8294OS_Code\Chapter01\src\main\
?????目錄???????????0??2014-03-24?16:48??8294OS_Code\Chapter01\src\main\java\
?????目錄???????????0??2014-03-24?16:48??8294OS_Code\Chapter01\src\main\java\storm\
?????目錄???????????0??2014-03-24?16:48??8294OS_Code\Chapter01\src\main\java\storm\blueprints\
?????目錄???????????0??2014-03-24?16:48??8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\
?????目錄???????????0??2014-03-24?16:48??8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v1\
?????文件????????1339??2014-03-24?16:48??8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v1\ReportBolt.java
?????文件????????1194??2014-03-24?16:48??8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v1\SentenceSpout.java
?????文件?????????958??2014-03-24?16:48??8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v1\SplitSentenceBolt.java
?????文件????????1167??2014-03-24?16:48??8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v1\WordCountBolt.java
?????文件????????1731??2014-03-24?16:48??8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v1\WordCountTopology.java
?????目錄???????????0??2014-03-24?16:48??8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v2\
?????文件????????1844??2014-03-24?16:48??8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v2\WordCountTopology.java
?????目錄???????????0??2014-03-24?16:48??8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v3\
?????文件????????1176??2014-03-24?16:48??8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v3\SentenceSpout.java
?????文件????????1844??2014-03-24?16:48??8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v3\WordCountTopology.java
?????文件????????1946??2014-03-24?16:48??8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v3\WordCountTopologyBroken.java
?????目錄???????????0??2014-03-24?16:48??8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v4\
?????文件????????1497??2014-03-24?16:48??8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v4\ReportBolt.java
?????文件????????1696??2014-03-24?16:48??8294OS_Code\Chapter01\src\main\java\storm\blueprints\chapter1\v4\SentenceSpout.java
............此處省略292個文件信息