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),數據做一次次處理(加上時間)。