Package org.apache.storm.scheduler
Interface INimbus
- All Known Implementing Classes:
- Nimbus.StandaloneINimbus
public interface INimbus
- 
Method SummaryModifier and TypeMethodDescriptionallSlotsAvailableForScheduling(Collection<SupervisorDetails> existingSupervisors, Topologies topologies, Set<String> topologiesMissingAssignments) Returns all slots that are available for the next round of scheduling.voidassignSlots(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
- 
allSlotsAvailableForSchedulingCollection<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.
- 
assignSlotsthis is called after the assignment is changed in ZK.
- 
getHostNamemap from node id to supervisor details.
- 
getForcedSchedulerIScheduler getForcedScheduler()
 
-