542
技術社區[雲棲]
Storm之LocalCluster.clj
此類初始化了一些配置參數，實現了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
最後更新：2017-04-01 13:38:49