标签:
任务调度接口定义:
1 | IScheduler{ |
2 | // conf为当前nimbus的stormp配置 |
3 | void prepare(Map conf); // 初始化 |
4 | // topologyies表示集群中所有topology信息,cluster表示当前集群包括用户自定义调度逻辑事所需的所有资源(Supervisor、Solt、以及任务分配情况) |
5 | void schedule(Topologies topologies,Cluster cluster); |
6 | }; |
实现流程图:
功能:对资源进行均匀分配的调度器,实现了IScheduler接口, schedule方法实现如下
1 | defn– schedule[this ^Topologies topologyies ^Cluster cluster] |
2 | (schedule-topologies-evenly topologies cluster) |
schedule-topologies-evenly方法原型:
1 | defn schedule-topologies-evenly[^Topologies topologies ^Cluster cluster] |
方法说明:
schedule-topology
方法原型:
1 | defn- schedule-topology [^TopologyDetails topology ~Cluster cluster] |
方法说明:
Storm系列(六)Scheduler-调度器[EventScheduler]
标签:
原文地址:http://www.cnblogs.com/jianyuan/p/4797404.html