天天看點

《Storm分布式實時計算模式》——3.7 執行topology

本節書摘來自華章計算機《storm分布式實時計算模式》一書中的第3章,第3.7節,作者:(美)p. taylor goetz brian o’neill 更多章節内容可以通路雲栖社群“華章計算機”公衆号檢視。

outbreakdetectiontopology類有下列方法:

《Storm分布式實時計算模式》——3.7 執行topology

https://yqfile.alicdn.com/f60f4a59d0169ba5d18c37d5992d18f5c1b86bfd.png

" >

執行這個方法會将topology部署到本地叢集中。spout會立即開始發送疾病事件,由count aggregator收集計數。outbreakdetector類中的門檻值故意設定得很小,這樣計數很快就超過門檻值,這時程式結束,輸出如下日志:

《Storm分布式實時計算模式》——3.7 執行topology

注意當資料批次成功處理完成時會通知到coordinator,并且在幾批資料後,就超過門檻值了,系統會通過錯誤消息告知我們:派遣國民警衛隊!

繼續閱讀