void prepare(Map conf)
void schedule(Topologies topologies, Cluster cluster)
Set assignments for the topologies which needs scheduling. The new assignments is available through
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- the cluster these topologies are running in.
clustercontains 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 © 2019 The Apache Software Foundation. All Rights Reserved.