3.7 执行topology
OutbreakDetectionTopology类有下列方法:
https://yqfile.alicdn.com/f60f4a59d0169ba5d18c37d5992d18f5c1b86bfd.png
" >
执行这个方法会将topology部署到本地集群中。spout会立即开始发送疾病事件,由Count aggregator收集计数。OutbreakDetector类中的阈值故意设置得很小,这样计数很快就超过阈值,这时程序结束,输出如下日志:
注意当数据批次成功处理完成时会通知到coordinator,并且在几批数据后,就超过阈值了,系统会通过错误消息告知我们:派遣国民警卫队!
时间: 2024-09-08 01:34:14