Interface ISupervisor

    • 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)