| Constructor and Description |
|---|
StandaloneINimbus() |
| Modifier and Type | Method and Description |
|---|---|
Collection<WorkerSlot> |
allSlotsAvailableForScheduling(Collection<SupervisorDetails> supervisors,
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)
this is called after the assignment is changed in ZK.
|
IScheduler |
getForcedScheduler() |
String |
getHostName(Map<String,SupervisorDetails> supervisors,
String nodeId)
map from node id to supervisor details.
|
void |
prepare(Map<String,Object> topoConf,
String schedulerLocalDir) |
public Collection<WorkerSlot> allSlotsAvailableForScheduling(Collection<SupervisorDetails> supervisors, Topologies topologies, Set<String> topologiesMissingAssignments)
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.
allSlotsAvailableForScheduling in interface INimbuspublic void assignSlots(Topologies topologies, Map<String,Collection<WorkerSlot>> newSlotsByTopologyId)
INimbusthis is called after the assignment is changed in ZK.
assignSlots in interface INimbuspublic String getHostName(Map<String,SupervisorDetails> supervisors, String nodeId)
INimbusmap from node id to supervisor details.
getHostName in interface INimbuspublic IScheduler getForcedScheduler()
getForcedScheduler in interface INimbusCopyright © 2021 The Apache Software Foundation. All rights reserved.