Package org.apache.storm.scheduler

# Interface ISupervisor

All Known Implementing Classes:
  `StandaloneSupervisor`

public interface ISupervisor

- ## Method Summary

  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 Details

  - ### prepare

    void prepare(Map<String,Object> topoConf, String schedulerLocalDir)

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