本节书摘来自华章计算机《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，并且在几批数据后，就超过阈值了，系统会通过错误消息告知我们：派遣国民警卫队!