org.apache.hadoop.hbase.client

Class TestClientNoCluster.RpcTimeoutAsyncConnection

java.lang.Object

org.apache.hadoop.hbase.client.AsyncConnectionImpl

org.apache.hadoop.hbase.client.TestClientNoCluster.RpcTimeoutAsyncConnection

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.hbase.client.AsyncConnection

Enclosing class:

TestClientNoCluster

static class TestClientNoCluster.RpcTimeoutAsyncConnection
extends org.apache.hadoop.hbase.client.AsyncConnectionImpl

Override to check we are setting rpc timeout right.

Field Summary

Fields inherited from class org.apache.hadoop.hbase.client.AsyncConnectionImpl

callerFactory, connConf, registry, RETRY_TIMER, rpcControllerFactory

Constructor Summary

Constructors

Constructor and Description
RpcTimeoutAsyncConnection(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.hbase.client.ConnectionRegistry registry, String clusterId, org.apache.hadoop.hbase.security.User user)

Method Summary

Methods inherited from class org.apache.hadoop.hbase.client.AsyncConnectionImpl

clearMasterStubCache, clearRegionLocationCache, close, getAdminBuilder, getAdminBuilder, getAdminStub, getBackoffPolicy, getBufferedMutatorBuilder, getBufferedMutatorBuilder, getChoreService, getClusterId, getConfiguration, getConnectionMetrics, getConnectionRegistry, getHbck, getHbck, getLocator, getMasterStub, getNonceGenerator, getRegionLocator, getRegionServerStub, getStatisticsTracker, getTableBuilder, getTableBuilder, getUser, isClosed

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.client.AsyncConnection

getAdmin, getAdmin, getBufferedMutator, getBufferedMutator, getTable, getTable

Constructor Detail

RpcTimeoutAsyncConnection

RpcTimeoutAsyncConnection(org.apache.hadoop.conf.Configuration configuration,
                          org.apache.hadoop.hbase.client.ConnectionRegistry registry,
                          String clusterId,
                          org.apache.hadoop.hbase.security.User user)