Class StandaloneSupervisor
java.lang.Object
org.apache.storm.daemon.supervisor.StandaloneSupervisor
- All Implemented Interfaces:
ISupervisor
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
assigned
(Collection<Integer> ports) boolean
confirmAssigned
(int port) The id used in assignments.The id used for writing metadata into ZK.void
killedWorker
(int port) void
-
Constructor Details
-
StandaloneSupervisor
public StandaloneSupervisor()
-
-
Method Details
-
prepare
- Specified by:
prepare
in interfaceISupervisor
-
getSupervisorId
Description copied from interface:ISupervisor
The id used for writing metadata into ZK.- Specified by:
getSupervisorId
in interfaceISupervisor
-
getAssignmentId
Description copied from interface:ISupervisor
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.- Specified by:
getAssignmentId
in interfaceISupervisor
-
getMetadata
- Specified by:
getMetadata
in interfaceISupervisor
-
confirmAssigned
public boolean confirmAssigned(int port) - Specified by:
confirmAssigned
in interfaceISupervisor
-
killedWorker
public void killedWorker(int port) - Specified by:
killedWorker
in interfaceISupervisor
-
assigned
- Specified by:
assigned
in interfaceISupervisor
-
generateSupervisorId
-