Package org.apache.storm.scheduler
Interface INimbus
- All Known Implementing Classes:
Nimbus.StandaloneINimbus
public interface INimbus
-
Method Summary
Modifier and TypeMethodDescriptionallSlotsAvailableForScheduling
(Collection<SupervisorDetails> existingSupervisors, Topologies topologies, Set<String> topologiesMissingAssignments) Returns all slots that are available for the next round of scheduling.void
assignSlots
(Topologies topologies, Map<String, Collection<WorkerSlot>> newSlotsByTopologyId) this is called after the assignment is changed in ZK.getHostName
(Map<String, SupervisorDetails> existingSupervisors, String nodeId) map from node id to supervisor details.void
-
Method Details
-
prepare
-
allSlotsAvailableForScheduling
Collection<WorkerSlot> allSlotsAvailableForScheduling(Collection<SupervisorDetails> existingSupervisors, Topologies topologies, Set<String> topologiesMissingAssignments) Returns all slots that are available for the next round of scheduling. A slot is available for scheduling if it is free and can be assigned to, or if it is used and can be reassigned. -
assignSlots
this is called after the assignment is changed in ZK. -
getHostName
map from node id to supervisor details. -
getForcedScheduler
IScheduler getForcedScheduler()
-