backtype.storm.scheduler
Interface ISupervisor


public interface ISupervisor


Method Summary
 void assigned(java.util.Collection<java.lang.Integer> ports)
           
 boolean confirmAssigned(int port)
           
 java.lang.String getId()
           
 java.lang.Object getMetadata()
           
 void killedWorker(int port)
           
 void prepare(java.util.Map stormConf, java.lang.String schedulerLocalDir)
           
 

Method Detail

prepare

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

getId

java.lang.String getId()

getMetadata

java.lang.Object getMetadata()

confirmAssigned

boolean confirmAssigned(int port)

killedWorker

void killedWorker(int port)

assigned

void assigned(java.util.Collection<java.lang.Integer> ports)