org.apache.storm.utils

Class DRPCClient

java.lang.Object

org.apache.storm.security.auth.ThriftClient

org.apache.storm.utils.DRPCClient

All Implemented Interfaces:

AutoCloseable, DistributedRPC.Iface

public class DRPCClient
extends ThriftClient
implements DistributedRPC.Iface

Field Summary

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

_protocol, _retryForever

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
String	execute(String func, String args)
DistributedRPC.Client	getClient()
String	getHost()
int	getPort()

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

Constructor Detail

DRPCClient

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

Throws:

org.apache.thrift.transport.TTransportException

DRPCClient

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

Throws:

org.apache.thrift.transport.TTransportException

Method Detail

getHost

public String getHost()

getPort

public int getPort()

execute

public String execute(String func,
                      String args)
               throws org.apache.thrift.TException,
                      DRPCExecutionException,
                      AuthorizationException

Specified by:

execute in interface DistributedRPC.Iface

Throws:

org.apache.thrift.TException

DRPCExecutionException

AuthorizationException

getClient

public DistributedRPC.Client getClient()