Package org.apache.storm.scheduler
Interface ISupervisor
-
- All Known Implementing Classes:
StandaloneSupervisor
public interface ISupervisor
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
assigned(Collection<Integer> ports)
boolean
confirmAssigned(int port)
String
getAssignmentId()
The id used in assignments.Object
getMetadata()
String
getSupervisorId()
The id used for writing metadata into ZK.void
killedWorker(int port)
void
prepare(Map<String,Object> topoConf, String schedulerLocalDir)
-
-
-
Method Detail
-
getSupervisorId
String getSupervisorId()
The id used for writing metadata into ZK.
-
getAssignmentId
String 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.
-
getMetadata
Object getMetadata()
-
confirmAssigned
boolean confirmAssigned(int port)
-
killedWorker
void killedWorker(int port)
-
assigned
void assigned(Collection<Integer> ports)
-
-