Package org.apache.storm.utils

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.

Field Summary

Fields inherited from class org.apache.storm.security.auth.ThriftClient

protocol, retryForever

Constructor Summary

Constructors

Constructor	Description
SupervisorClient(Map conf, String host)
SupervisorClient(Map conf, String host, int port)
SupervisorClient(Map conf, String host, int port, Integer timeout)
SupervisorClient(Map conf, String host, Integer port, Integer timeout, String asUser)

Method Summary

Modifier and Type	Method	Description
static SupervisorClient	getConfiguredClient(Map conf, String host)
static SupervisorClient	getConfiguredClient(Map conf, String host, int port)
static SupervisorClient	getConfiguredClientAs(Map conf, String host, int port, String asUser)
Supervisor.Client	getIface()

Methods inherited from class org.apache.storm.security.auth.ThriftClient

close, reconnect, transport

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.storm.utils.SupervisorIfaceFactory

close

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

getConfiguredClient

public static SupervisorClient getConfiguredClient(Map conf,
 String host)

getConfiguredClient

public static SupervisorClient getConfiguredClient(Map conf,
 String host,
 int port)

getConfiguredClientAs

public static SupervisorClient getConfiguredClientAs(Map conf,
 String host,
 int port,
 String asUser)

getIface

public Supervisor.Client getIface()

Specified by:

getIface in interface SupervisorIfaceFactory