public interface IScheduler
Modifier and Type | Method and Description |
---|---|
void |
prepare(Map conf) |
void |
schedule(Topologies topologies,
Cluster cluster)
Set assignments for the topologies which needs scheduling.
|
void prepare(Map conf)
void schedule(Topologies topologies, Cluster cluster)
cluster.getAssignments()
topologies
- 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
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.