public class DRPCClient extends ThriftClient implements DistributedRPC.Iface
| Modifier and Type | Class and Description |
|---|---|
static class |
DRPCClient.LocalOverride |
protocol, retryForever| Constructor and Description |
|---|
DRPCClient(Map<String,Object> conf,
String host,
int port) |
DRPCClient(Map<String,Object> conf,
String host,
int port,
Integer timeout) |
| Modifier and Type | Method and Description |
|---|---|
String |
execute(String func,
String args) |
DistributedRPC.Iface |
getClient() |
static DRPCClient |
getConfiguredClient(Map<String,Object> conf) |
String |
getHost() |
static String |
getOverrideServiceId()
Get override service ID.
|
int |
getPort() |
static boolean |
isLocalOverride()
Check local override.
|
close, reconnect, transportpublic DRPCClient(Map<String,Object> conf, String host, int port) throws org.apache.storm.thrift.transport.TTransportException
org.apache.storm.thrift.transport.TTransportExceptionpublic static boolean isLocalOverride()
Check local override.
public static String getOverrideServiceId()
Get override service ID.
public static DRPCClient getConfiguredClient(Map<String,Object> conf) throws org.apache.storm.thrift.transport.TTransportException
org.apache.storm.thrift.transport.TTransportExceptionpublic String getHost()
public int getPort()
public String execute(String func, String args) throws org.apache.storm.thrift.TException, DRPCExecutionException, AuthorizationException
execute in interface DistributedRPC.Ifaceorg.apache.storm.thrift.TExceptionDRPCExecutionExceptionAuthorizationExceptionpublic DistributedRPC.Iface getClient()
Copyright © 2021 The Apache Software Foundation. All rights reserved.