542      阿里云  技术社区[云栖]

Storm之LocalCluster.clj

       此类初始化了一些配置参数，实现了ILocalCluster接口，将拓扑结构提交到nimbus，最终通过nimbus来执行

其中最重要的看

gen-class中定义了init的函数名为”init”，继承了ILocalCluster接口

下面看init函数：

定义了3种init函数

1. 无参数 设置了TOPOLOGY-ENABLE-MESSAGE-TIMEOUTS，返回ret作为state

1. String 和 Long 两个参数，分别制定zookeeper的Host和Port，返回ret作为state

1. java中的Map，直接返回，将map当做state

最后更新：2017-04-01 13:38:49

  上一篇： PostgreSQL 聚合函数讲解 - 7 窗口反聚合

  下一篇： Windows 2008