public interface INimbus
Modifier and Type | Method and Description |
---|---|
Collection<WorkerSlot> |
allSlotsAvailableForScheduling(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) |
IScheduler |
getForcedScheduler() |
String |
getHostName(Map<String,SupervisorDetails> existingSupervisors,
String nodeId) |
void |
prepare(Map stormConf,
String schedulerLocalDir) |
Collection<WorkerSlot> allSlotsAvailableForScheduling(Collection<SupervisorDetails> existingSupervisors, Topologies topologies, Set<String> topologiesMissingAssignments)
void assignSlots(Topologies topologies, Map<String,Collection<WorkerSlot>> newSlotsByTopologyId)
String getHostName(Map<String,SupervisorDetails> existingSupervisors, String nodeId)
IScheduler getForcedScheduler()
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.