此类初始化了一些配置参数,实现了ILocalCluster接口,将拓扑结构提交到nimbus,最终通过nimbus来执行
其中最重要的看
gen-class中定义了init的函数名为”init”,继承了ILocalCluster接口
下面看init函数:
定义了3种init函数
- 无参数 设置了TOPOLOGY-ENABLE-MESSAGE-TIMEOUTS,返回ret作为state
- String 和 Long 两个参数,分别制定zookeeper的Host和Port,返回ret作为state
- java中的Map,直接返回,将map当做state