Package org.apache.storm.daemon.nimbus
Class Nimbus.StandaloneINimbus
java.lang.Object
org.apache.storm.daemon.nimbus.Nimbus.StandaloneINimbus
- All Implemented Interfaces:
INimbus
- Enclosing class:
- Nimbus
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionallSlotsAvailableForScheduling(Collection<SupervisorDetails> supervisors, 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> supervisors, String nodeId) map from node id to supervisor details.void
-
Constructor Details
-
StandaloneINimbus
public StandaloneINimbus()
-
-
Method Details
-
prepare
-
allSlotsAvailableForScheduling
public Collection<WorkerSlot> allSlotsAvailableForScheduling(Collection<SupervisorDetails> supervisors, Topologies topologies, Set<String> topologiesMissingAssignments) Description copied from interface:INimbusReturns 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.- Specified by:
allSlotsAvailableForSchedulingin interfaceINimbus
-
assignSlots
public void assignSlots(Topologies topologies, Map<String, Collection<WorkerSlot>> newSlotsByTopologyId) Description copied from interface:INimbusthis is called after the assignment is changed in ZK.- Specified by:
assignSlotsin interfaceINimbus
-
getHostName
Description copied from interface:INimbusmap from node id to supervisor details.- Specified by:
getHostNamein interfaceINimbus
-
getForcedScheduler
- Specified by:
getForcedSchedulerin interfaceINimbus
-