Hadoop 面试题之storm （3）
Hadoop 面试题之八 355.metaq 消息队列 zookeeper 集群 storm集群(包括 zeromq,jzmq,和 storm 本身)就可以完成对商城推荐系统功能吗？还有其他的中间件？356.storm怎么完成对单词的计数？（个人看完storm 后一直都认为他是流处理，好像没有积攒数据的能力，都是处理完之后直接分发给下一个组件）357.storm 其他的一些面试经常
·
storm怎么完成对单词的计数？（个人看完storm 后一直都认为他是流处理，好像没有积攒数据的能力，都是处理完之后直接分发给下一个组件）
【SplitBolt接收SentenceSpout发射的tuple，它将每句话分割成每个单词，并将每个单词作为tuple发射。再次，WordCountBolt接收SplitBolt发送的tuple，它将接收到的每一个单词统计计数，并将 <单词：出现次数> 作为tuple发射。最后，ReportBolt接收WordCountBolt发送的tuple，将统计的结果存入HashMap中，并打印出结果。】
1、一个spout发射tuple
2、一个splitbolt将一行数据进行分解
3、woordcount 将接收到的单词进行计数
4、任何reportbolt将结果保存在hashmap中，然后打印结果
权威｜前沿｜技术｜干货｜国内首个API全生命周期开发者社区
更多推荐
0
0- 0
已为社区贡献1条内容
所有评论(0)