Storm的单词统计设计
一:Storm的wordCount和Hadoop的wordCount实例对比
二:Storm的wordCount的方案实例设计
三:建立maven项目,添加maven相关依赖包
(1)输入:search.maven.org网址,在其中找到storm的核心依赖
(2)将核心依赖添加到pom.xml文件中
com.github.aloomaio
storm-core
0.9.2-incubating
四:代码实现
一:WordCountTopology源码【启动topology的入口】
View Code
二:RandomSentenceSpout源码【发送英语句子的消息源头】
View Code
三:WordNormalizerBolt源码【将英语句子的切割成单词的处理逻辑单元】
View Code
四:WordCountBolt源码【进行单词统计的处理逻辑单元】
View Code
五:PrintBolt源码【进行单词topN的打印单元】
View Code
六:MapSort源码【进行单词排序】
View Code