storm编程的基本概念-topo-spout-bolt
例如下:
storm 编程接口-spout的结构及组件实现
storm编程案例-spout组件-实现
这是我的第一个组件(spout组件继承BaseRichSput)所有重写内部的三个方法,用于接收数据(这里数据是先造的)和数据传出。
storm编程案例-bolt组件A-实现
实现Bolt组件,这是我的第二个组件(Bolt组件继承BaseBasicBolt)所有重写内部的方法,用于接收spout数据(phone-name),数据做一次次处理(转化大写)。
storm编程案例-bolt组件B-实现
实现Bolt组件,这是我的第三个组件(Bolt组件继承BaseBasicBolt)所有重写内部的方法,用于接收上一个Bolt数据(phone-name),数据做一次次处理(加上时间)。