@InterfaceAudience.Private public interface RpcClient extends Closeable
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_CODEC_CLASS |
static int |
DEFAULT_SOCKET_TIMEOUT_CONNECT |
static int |
DEFAULT_SOCKET_TIMEOUT_READ |
static int |
DEFAULT_SOCKET_TIMEOUT_WRITE |
static int |
FAILED_SERVER_EXPIRY_DEFAULT |
static String |
FAILED_SERVER_EXPIRY_KEY |
static String |
IDLE_TIME |
static boolean |
IPC_CLIENT_FALLBACK_TO_SIMPLE_AUTH_ALLOWED_DEFAULT |
static String |
IPC_CLIENT_FALLBACK_TO_SIMPLE_AUTH_ALLOWED_KEY |
static int |
PING_CALL_ID |
static String |
SOCKET_TIMEOUT_CONNECT |
static String |
SOCKET_TIMEOUT_READ
How long we wait when we wait for an answer.
|
static String |
SOCKET_TIMEOUT_WRITE |
static String |
SPECIFIC_WRITE_THREAD |
Modifier and Type | Method and Description |
---|---|
void |
cancelConnections(ServerName sn)
Interrupt the connections to the given server.
|
void |
close()
Stop all threads related to this client.
|
org.apache.hbase.thirdparty.com.google.protobuf.BlockingRpcChannel |
createBlockingRpcChannel(ServerName sn,
User user,
int rpcTimeout)
Creates a "channel" that can be used by a blocking protobuf service.
|
org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel |
createRpcChannel(ServerName sn,
User user,
int rpcTimeout)
Creates a "channel" that can be used by a protobuf service.
|
boolean |
hasCellBlockSupport()
Return true when this client uses a
Codec and so supports
cell blocks. |
static final String FAILED_SERVER_EXPIRY_KEY
static final int FAILED_SERVER_EXPIRY_DEFAULT
static final String IDLE_TIME
static final String IPC_CLIENT_FALLBACK_TO_SIMPLE_AUTH_ALLOWED_KEY
static final boolean IPC_CLIENT_FALLBACK_TO_SIMPLE_AUTH_ALLOWED_DEFAULT
static final String SPECIFIC_WRITE_THREAD
static final String DEFAULT_CODEC_CLASS
static final String SOCKET_TIMEOUT_CONNECT
static final String SOCKET_TIMEOUT_READ
static final String SOCKET_TIMEOUT_WRITE
static final int DEFAULT_SOCKET_TIMEOUT_CONNECT
static final int DEFAULT_SOCKET_TIMEOUT_READ
static final int DEFAULT_SOCKET_TIMEOUT_WRITE
static final int PING_CALL_ID
org.apache.hbase.thirdparty.com.google.protobuf.BlockingRpcChannel createBlockingRpcChannel(ServerName sn, User user, int rpcTimeout)
sn
- server name describing location of serveruser
- which is to use the connectionrpcTimeout
- default rpc operation timeoutorg.apache.hbase.thirdparty.com.google.protobuf.RpcChannel createRpcChannel(ServerName sn, User user, int rpcTimeout)
sn
- server name describing location of serveruser
- which is to use the connectionrpcTimeout
- default rpc operation timeoutvoid cancelConnections(ServerName sn)
sn
- server location to cancel connections ofvoid close()
close
in interface AutoCloseable
close
in interface Closeable
boolean hasCellBlockSupport()
Codec
and so supports
cell blocks.Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.