本节书摘来自华章计算机《Storm分布式实时计算模式》一书中的第3章,第3.7节,作者:(美)P. Taylor Goetz Brian O’Neill 更多章节内容可以访问云栖社区“华章计算机”公众号查看。
3.7 执行topology
OutbreakDetectionTopology类有下列方法:
https://yqfile.alicdn.com/f60f4a59d0169ba5d18c37d5992d18f5c1b86bfd.png
" >
执行这个方法会将topology部署到本地集群中。spout会立即开始发送疾病事件,由Count aggregator收集计数。OutbreakDetector类中的阈值故意设置得很小,这样计数很快就超过阈值,这时程序结束,输出如下日志:
注意当数据批次成功处理完成时会通知到coordinator,并且在几批数据后,就超过阈值了,系统会通过错误消息告知我们:派遣国民警卫队!