Class StandaloneSupervisor

All Implemented Interfaces:

public class StandaloneSupervisor extends Object implements ISupervisor
  • Constructor Details

    • StandaloneSupervisor

      public StandaloneSupervisor()
  • Method Details

    • prepare

      public void prepare(Map<String,Object> topoConf, String schedulerLocalDir)
      Specified by:
      prepare in interface ISupervisor
    • getSupervisorId

      public String getSupervisorId()
      Description copied from interface: ISupervisor
      The id used for writing metadata into ZK.
      Specified by:
      getSupervisorId in interface ISupervisor
    • getAssignmentId

      public String 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 interface ISupervisor
    • getMetadata

      public Object getMetadata()
      Specified by:
      getMetadata in interface ISupervisor
    • confirmAssigned

      public boolean confirmAssigned(int port)
      Specified by:
      confirmAssigned in interface ISupervisor
    • killedWorker

      public void killedWorker(int port)
      Specified by:
      killedWorker in interface ISupervisor
    • assigned

      public void assigned(Collection<Integer> ports)
      Specified by:
      assigned in interface ISupervisor
    • generateSupervisorId

      public String generateSupervisorId()