Package org.apache.storm.daemon.nimbus
Class Nimbus.StandaloneINimbus
- java.lang.Object
-
- org.apache.storm.daemon.nimbus.Nimbus.StandaloneINimbus
-
-
Constructor Summary
Constructors Constructor Description StandaloneINimbus()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Collection<WorkerSlot>allSlotsAvailableForScheduling(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.ISchedulergetForcedScheduler()StringgetHostName(Map<String,SupervisorDetails> supervisors, String nodeId)map from node id to supervisor details.voidprepare(Map<String,Object> topoConf, String schedulerLocalDir)
-
-
-
Method Detail
-
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
public String getHostName(Map<String,SupervisorDetails> supervisors, String nodeId)
Description copied from interface:INimbusmap from node id to supervisor details.- Specified by:
getHostNamein interfaceINimbus
-
getForcedScheduler
public IScheduler getForcedScheduler()
- Specified by:
getForcedSchedulerin interfaceINimbus
-
-