backtype.storm.utils

Class NimbusClient

java.lang.Object

backtype.storm.security.auth.ThriftClient

backtype.storm.utils.NimbusClient

public class NimbusClient
extends ThriftClient

Field Summary

Fields inherited from class backtype.storm.security.auth.ThriftClient

_protocol

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
Nimbus.Client	getClient()
static NimbusClient	getConfiguredClient(Map conf)
static NimbusClient	getConfiguredClientAs(Map conf, String asUser)

Methods inherited from class backtype.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

Constructor Detail

NimbusClient

public NimbusClient(Map conf,
            String host,
            int port)
             throws org.apache.thrift.transport.TTransportException

Throws:

org.apache.thrift.transport.TTransportException

NimbusClient

public NimbusClient(Map conf,
            String host,
            int port,
            Integer timeout)
             throws org.apache.thrift.transport.TTransportException

Throws:

org.apache.thrift.transport.TTransportException

NimbusClient

public NimbusClient(Map conf,
            String host,
            Integer port,
            Integer timeout,
            String asUser)
             throws org.apache.thrift.transport.TTransportException

Throws:

org.apache.thrift.transport.TTransportException

NimbusClient

public NimbusClient(Map conf,
            String host)
             throws org.apache.thrift.transport.TTransportException

Throws:

org.apache.thrift.transport.TTransportException

Method Detail

getConfiguredClient

public static NimbusClient getConfiguredClient(Map conf)

getConfiguredClientAs

public static NimbusClient getConfiguredClientAs(Map conf,
                                 String asUser)

getClient

public Nimbus.Client getClient()