《Storm分布式实时计算模式》——3.7 执行topology

    xiaoxiao2023-09-19  165

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

    相关资源:敏捷开发V1.0.pptx
    最新回复(0)