Class StandaloneSupervisor
java.lang.Object
org.apache.storm.daemon.supervisor.StandaloneSupervisor
- All Implemented Interfaces:
- ISupervisor
- 
Constructor SummaryConstructors
- 
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
- 
Constructor Details- 
StandaloneSupervisorpublic StandaloneSupervisor()
 
- 
- 
Method Details- 
prepare- Specified by:
- preparein interface- ISupervisor
 
- 
getSupervisorIdDescription copied from interface:ISupervisorThe id used for writing metadata into ZK.- Specified by:
- getSupervisorIdin interface- ISupervisor
 
- 
getAssignmentIdDescription copied from interface:ISupervisorThe 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.- Specified by:
- getAssignmentIdin interface- ISupervisor
 
- 
getMetadata- Specified by:
- getMetadatain interface- ISupervisor
 
- 
confirmAssignedpublic boolean confirmAssigned(int port) - Specified by:
- confirmAssignedin interface- ISupervisor
 
- 
killedWorkerpublic void killedWorker(int port) - Specified by:
- killedWorkerin interface- ISupervisor
 
- 
assigned- Specified by:
- assignedin interface- ISupervisor
 
- 
generateSupervisorId
 
-