org.apache.storm.scheduler

Interface INimbus

public interface INimbus

Method Summary

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) this is called after the assignment is changed in ZK
IScheduler	getForcedScheduler()
String	getHostName(Map<String,SupervisorDetails> existingSupervisors, String nodeId) map from node id to supervisor details
void	prepare(Map stormConf, String schedulerLocalDir)

Method Detail

prepare

void prepare(Map stormConf,
             String schedulerLocalDir)

allSlotsAvailableForScheduling

Collection<WorkerSlot> allSlotsAvailableForScheduling(Collection<SupervisorDetails> existingSupervisors,
                                                      Topologies topologies,
                                                      Set<String> topologiesMissingAssignments)

Returns 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.

assignSlots

void assignSlots(Topologies topologies,
                 Map<String,Collection<WorkerSlot>> newSlotsByTopologyId)

this is called after the assignment is changed in ZK

Parameters:

topologies -

newSlotsByTopologyId -

getHostName

String getHostName(Map<String,SupervisorDetails> existingSupervisors,
                   String nodeId)

map from node id to supervisor details

Parameters:

existingSupervisors -

nodeId -

Returns:

getForcedScheduler

IScheduler getForcedScheduler()