public class StandaloneSupervisor extends Object implements ISupervisor
| Constructor and Description |
|---|
StandaloneSupervisor() |
| Modifier and Type | Method and Description |
|---|---|
void |
assigned(Collection<Integer> ports) |
boolean |
confirmAssigned(int port) |
String |
generateSupervisorId() |
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) |
public void prepare(Map<String,Object> topoConf, String schedulerLocalDir)
prepare in interface ISupervisorpublic String getSupervisorId()
ISupervisorThe id used for writing metadata into ZK.
getSupervisorId in interface ISupervisorpublic String getAssignmentId()
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.
getAssignmentId in interface ISupervisorpublic Object getMetadata()
getMetadata in interface ISupervisorpublic boolean confirmAssigned(int port)
confirmAssigned in interface ISupervisorpublic void killedWorker(int port)
killedWorker in interface ISupervisorpublic void assigned(Collection<Integer> ports)
assigned in interface ISupervisorpublic String generateSupervisorId()
Copyright © 2021 The Apache Software Foundation. All rights reserved.