Jstorm源码中的kill及rebanlance及activate/deactivate方法运行流程
发布时间
阅读量:
阅读量
将这几个kill、rebanlance、activate、deactivate方法进行集中分析的原因在于,它们均基于nimbus所定义的通用状态转移机制实现功能。
transitionName
***********这里只具体分析kill方法
一:LocalCluster的初始化过程与拓扑提交方式相似,具体细节可参考大神http://www.maoxiangyi.cn/index.php/archives/734;
二:在LocalCluster构建完成之后,可以通过调用killTopology或killTopologyWithOpts方法来终止拓扑运行。
这些方法的执行过程中,均会触发对nimbus相应功能的调用。若对nimbus的具体实现类进行追踪,即可发现killTopology与killTopologyWithOpts这两个方法的实际执行逻辑均被封装于killTopologyWithOpts之中
@Override
public void killTopology(String name) throws NotAliveException, TException {
全部评论 (0)
还没有任何评论哟~
