Class SupervisorClient

java.lang.Object
org.apache.storm.security.auth.ThriftClient
org.apache.storm.utils.SupervisorClient
All Implemented Interfaces:
Closeable, AutoCloseable, SupervisorIfaceFactory

public class SupervisorClient extends ThriftClient implements SupervisorIfaceFactory
Client for interacting with Supervisor server, now we use supervisor server mainly for cases below.
  • worker <- supervisor: get worker local assignment for a storm.
  • nimbus -> supervisor: assign assignments for a node.
  • Constructor Details

    • SupervisorClient

      public SupervisorClient(Map conf, String host, int port) throws org.apache.storm.thrift.transport.TTransportException
      Throws:
      org.apache.storm.thrift.transport.TTransportException
    • SupervisorClient

      public SupervisorClient(Map conf, String host, int port, Integer timeout) throws org.apache.storm.thrift.transport.TTransportException
      Throws:
      org.apache.storm.thrift.transport.TTransportException
    • SupervisorClient

      public SupervisorClient(Map conf, String host, Integer port, Integer timeout, String asUser) throws org.apache.storm.thrift.transport.TTransportException
      Throws:
      org.apache.storm.thrift.transport.TTransportException
    • SupervisorClient

      public SupervisorClient(Map conf, String host) throws org.apache.storm.thrift.transport.TTransportException
      Throws:
      org.apache.storm.thrift.transport.TTransportException
  • Method Details