• Jstorm源码分析--kill、rebanlance、activate、deactivate方法流程

    时间:2022-05-15 09:23:09

    这几个kill、rebanlance、activate、deactivate方法放在一起分析,是因为他们都依赖于nimbus定义的通用的 状态转移方法: transitionName********************************************这里只具体分析kill方法**...

  • JStorm与Storm源码分析(三)--Scheduler,调度器

    时间:2021-10-05 09:20:06

    Scheduler作为Storm的调度器,负责为Topology分配可用资源。 Storm提供了IScheduler接口,用户可以通过实现该接口来自定义Scheduler。 其定义如下:public interface IScheduler {//接收当前Nimbus的Storm配置作为参数,进行一...