Overview  Package   Class  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

backtype.storm.scheduler
Interface INimbus

public interface INimbus

Method Summary
 void assignSlots(Topologies topologies, java.util.Collection<WorkerSlot> newSlots)
           
 java.util.Collection<WorkerSlot> availableSlots(java.util.Collection<SupervisorDetails> existingSupervisors, java.util.Collection<WorkerSlot> usedSlots, Topologies topologies, java.util.Collection<java.lang.String> topologiesWithMissingAssignments)
           
 IScheduler getForcedScheduler()
           
 java.lang.String getHostName(java.util.Map<java.lang.String,SupervisorDetails> existingSupervisors, java.lang.String nodeId)
           
 void prepare(java.util.Map stormConf, java.lang.String schedulerLocalDir)
           
 

Method Detail

prepare

void prepare(java.util.Map stormConf,
             java.lang.String schedulerLocalDir)

availableSlots

java.util.Collection<WorkerSlot> availableSlots(java.util.Collection<SupervisorDetails> existingSupervisors,
                                                java.util.Collection<WorkerSlot> usedSlots,
                                                Topologies topologies,
                                                java.util.Collection<java.lang.String> topologiesWithMissingAssignments)

assignSlots

void assignSlots(Topologies topologies,
                 java.util.Collection<WorkerSlot> newSlots)

getHostName

java.lang.String getHostName(java.util.Map<java.lang.String,SupervisorDetails> existingSupervisors,
                             java.lang.String nodeId)

getForcedScheduler

IScheduler getForcedScheduler()
Overview  Package   Class  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD