Package org.apache.storm.scheduler
Interface ISupervisor
- All Known Implementing Classes:
- StandaloneSupervisor
public interface ISupervisor
- 
Method SummaryModifier and TypeMethodDescriptionvoidassigned(Collection<Integer> ports) booleanconfirmAssigned(int port) The id used in assignments.The id used for writing metadata into ZK.voidkilledWorker(int port) void
- 
Method Details- 
prepare
- 
getSupervisorIdString getSupervisorId()The id used for writing metadata into ZK.
- 
getAssignmentIdString getAssignmentId()The id used in assignments. This combined with confirmAssigned decides what this supervisor is responsible for. The combination of this and getSupervisorId allows Nimbus to assign to a single machine and have multiple supervisors on that machine execute the assignment. This is important for achieving resource isolation.
- 
getMetadataObject getMetadata()
- 
confirmAssignedboolean confirmAssigned(int port) 
- 
killedWorkervoid killedWorker(int port) 
- 
assigned
 
-