public class DefaultScheduler extends Object implements IScheduler
| Constructor and Description |
|---|
DefaultScheduler() |
| Modifier and Type | Method and Description |
|---|---|
Map<String,Map<String,Double>> |
config()
This function returns the scheduler’s configuration.
|
static void |
defaultSchedule(Topologies topologies,
Cluster cluster) |
void |
prepare(Map<String,Object> conf,
StormMetricsRegistry metricsRegistry) |
void |
schedule(Topologies topologies,
Cluster cluster)
Set assignments for the topologies which needs scheduling.
|
static Set<WorkerSlot> |
slotsCanReassign(Cluster cluster,
Set<WorkerSlot> slots) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcleanupnodeAssignmentSentpublic static Set<WorkerSlot> slotsCanReassign(Cluster cluster, Set<WorkerSlot> slots)
public static void defaultSchedule(Topologies topologies, Cluster cluster)
public void prepare(Map<String,Object> conf, StormMetricsRegistry metricsRegistry)
prepare in interface ISchedulerpublic void schedule(Topologies topologies, Cluster cluster)
ISchedulerSet assignments for the topologies which needs scheduling. The new assignments is available through cluster.getAssignments()
schedule in interface ISchedulertopologies - all the topologies in the cluster, some of them need schedule. Topologies object here only contain static information about topologies. Information like assignments, slots are all in the cluster object.cluster - the cluster these topologies are running in. cluster contains everything user need to develop a new scheduling logic. e.g. supervisors information, available slots, current assignments for all the topologies etc. User can set the new assignment for topologies using cluster.setAssignmentById()`public Map<String,Map<String,Double>> config()
ISchedulerThis function returns the scheduler’s configuration.
config in interface ISchedulerCopyright © 2021 The Apache Software Foundation. All rights reserved.