backtype.storm.utils
Class DRPCClient

java.lang.Object
  backtype.storm.utils.DRPCClient

public class DRPCClient
extends java.lang.Object

Constructor Summary

DRPCClient(java.lang.String host, int port)

DRPCClient(java.lang.String host, int port, java.lang.Integer timeout)

Method Summary

void	close()
java.lang.String	execute(java.lang.String func, java.lang.String args)
java.lang.String	getHost()
int	getPort()

Methods inherited from class java.lang.Object

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

Constructor Detail

DRPCClient

public DRPCClient(java.lang.String host,
                  int port,
                  java.lang.Integer timeout)

DRPCClient

public DRPCClient(java.lang.String host,
                  int port)

Method Detail

getHost

public java.lang.String getHost()

getPort

public int getPort()

execute

public java.lang.String execute(java.lang.String func,
                                java.lang.String args)
                         throws TException,
                                DRPCExecutionException

Throws:

TException

DRPCExecutionException

close

public void close()