MAPREDUCE服务 MRS-Storm样例程序开发思路:功能分解
功能分解
根据上述场景进行功能分解,如表1所示。
序号 |
步骤 |
代码示例 |
---|---|---|
1 |
创建一个Spout用来生成随机文本 |
|
2 |
创建一个Bolt用来将收到的随机文本拆分成一个个单词 |
请参见创建Storm Bolt |
3 |
创建一个Blot用来统计收到的各单词次数 |
请参见创建Storm Bolt |
4 |
创建topology |
部分代码请参考创建Storm Spout,创建Storm Bolt,创建Storm Topology,完整代码请参考Storm-examples示例工程。