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 SummaryConstructors
- 
Method SummaryModifier 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- 
StandaloneINimbuspublic StandaloneINimbus()
 
- 
- 
Method Details- 
prepare
- 
allSlotsAvailableForSchedulingpublic 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 interface- INimbus
 
- 
assignSlotspublic 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 interface- INimbus
 
- 
getHostNameDescription copied from interface:INimbusmap from node id to supervisor details.- Specified by:
- getHostNamein interface- INimbus
 
- 
getForcedScheduler- Specified by:
- getForcedSchedulerin interface- INimbus
 
 
-