Package 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
- 
Nested Class SummaryNested Classes
- 
Field SummaryFields inherited from class org.apache.storm.security.auth.ThriftClientprotocol, retryForever
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic DRPCClientgetConfiguredClient(Map<String, Object> conf) getHost()static StringGet override service ID.intgetPort()static booleanCheck local override.Methods inherited from class org.apache.storm.security.auth.ThriftClientclose, getKeyStoreFile, getPrivateKey, reconnect, transport
- 
Constructor Details- 
DRPCClientpublic DRPCClient(Map<String, Object> conf, String host, int port) throws org.apache.storm.thrift.transport.TTransportException- Throws:
- org.apache.storm.thrift.transport.TTransportException
 
- 
DRPCClientpublic DRPCClient(Map<String, Object> conf, String host, int port, Integer timeout) throws org.apache.storm.thrift.transport.TTransportException- Throws:
- org.apache.storm.thrift.transport.TTransportException
 
 
- 
- 
Method Details- 
isLocalOverridepublic static boolean isLocalOverride()Check local override.- Returns:
- true of new clients will be overridden to connect to a local cluster and not the configured remote cluster
 
- 
getOverrideServiceIdGet override service ID.- Returns:
- the service ID of the local override DRPC instance
 
- 
getConfiguredClientpublic static DRPCClient getConfiguredClient(Map<String, Object> conf) throws org.apache.storm.thrift.transport.TTransportException- Throws:
- org.apache.storm.thrift.transport.TTransportException
 
- 
getHost
- 
getPortpublic int getPort()
- 
executepublic String execute(String func, String args) throws org.apache.storm.thrift.TException, DRPCExecutionException, AuthorizationException - Specified by:
- executein interface- DistributedRPC.Iface
- Throws:
- org.apache.storm.thrift.TException
- DRPCExecutionException
- AuthorizationException
 
- 
getClient
 
-