Uses of Interface
org.apache.hadoop.hbase.client.ClusterConnection

Packages that use ClusterConnection

Package	Description
org.apache.hadoop.hbase
org.apache.hadoop.hbase.backup.example
org.apache.hadoop.hbase.client	Provides HBase Client
org.apache.hadoop.hbase.ipc	Tools to help define network clients and servers.
org.apache.hadoop.hbase.master
org.apache.hadoop.hbase.regionserver
org.apache.hadoop.hbase.regionserver.handler

Uses of ClusterConnection in org.apache.hadoop.hbase

Methods in org.apache.hadoop.hbase that return ClusterConnection

Modifier and Type	Method and Description
ClusterConnection	Server.getConnection() Returns a reference to the servers' cluster connection.

Uses of ClusterConnection in org.apache.hadoop.hbase.backup.example

Constructors in org.apache.hadoop.hbase.backup.example with parameters of type ClusterConnection

Constructor and Description
ZKTableArchiveClient(org.apache.hadoop.conf.Configuration conf, ClusterConnection connection)

Uses of ClusterConnection in org.apache.hadoop.hbase.client

Classes in org.apache.hadoop.hbase.client that implement ClusterConnection

Modifier and Type	Class and Description
class	CoprocessorHConnection Connection to an HTable from within a Coprocessor.

Fields in org.apache.hadoop.hbase.client declared as ClusterConnection

Modifier and Type	Field and Description
protected ClusterConnection	ScannerCallable.cConnection
protected ClusterConnection	RpcRetryingCallerWithReadReplicas.cConnection
protected ClusterConnection	RegionAdminServiceCallable.connection
protected ClusterConnection	HTable.connection
protected ClusterConnection	BufferedMutatorImpl.connection

Methods in org.apache.hadoop.hbase.client that return ClusterConnection

Modifier and Type	Method and Description
static ClusterConnection	ConnectionUtils.createShortCircuitConnection(org.apache.hadoop.conf.Configuration conf, ExecutorService pool, User user, ServerName serverName, AdminProtos.AdminService.BlockingInterface admin, ClientProtos.ClientService.BlockingInterface client) Creates a short-circuit connection that can bypass the RPC layer (serialization, deserialization, networking, etc..) when talking to a local server.
static ClusterConnection	ConnectionUtils.createShortCircuitHConnection(Connection conn, ServerName serverName, AdminProtos.AdminService.BlockingInterface admin, ClientProtos.ClientService.BlockingInterface client) Deprecated.
ClusterConnection	ScannerCallable.getConnection()
protected ClusterConnection	ClientScanner.getConnection()
static ClusterConnection	CoprocessorHConnection.getConnectionForEnvironment(CoprocessorEnvironment env) Create an unmanaged HConnection based on the environment in which we are running the coprocessor.

Methods in org.apache.hadoop.hbase.client with parameters of type ClusterConnection

Modifier and Type	Method and Description
org.apache.hadoop.hbase.client.ScannerCallableWithReplicas	ClientSmallScanner.SmallScannerCallableFactory.getCallable(ClusterConnection connection, TableName table, Scan scan, ScanMetrics scanMetrics, byte[] localStartKey, int cacheNum, RpcControllerFactory controllerFactory, ExecutorService pool, int primaryOperationTimeout, int retries, int scannerTimeout, org.apache.hadoop.conf.Configuration conf, RpcRetryingCaller<Result[]> caller)
static RegionLocations	RegionAdminServiceCallable.getRegionLocations(ClusterConnection connection, TableName tableName, byte[] row, boolean useCache, int replicaId)
static NonceGenerator	ConnectionUtils.injectNonceGeneratorForTesting(ClusterConnection conn, NonceGenerator cnm)

Constructors in org.apache.hadoop.hbase.client with parameters of type ClusterConnection

Constructor and Description
ClientScanner(org.apache.hadoop.conf.Configuration conf, Scan scan, TableName tableName, ClusterConnection connection, RpcRetryingCallerFactory rpcFactory, RpcControllerFactory controllerFactory, ExecutorService pool, int primaryOperationTimeout) Create a new ClientScanner for the specified table Note that the passed Scan's start row maybe changed changed.
ClientSmallReversedScanner(org.apache.hadoop.conf.Configuration conf, Scan scan, TableName tableName, ClusterConnection connection, RpcRetryingCallerFactory rpcFactory, RpcControllerFactory controllerFactory, ExecutorService pool, int primaryOperationTimeout) Create a new ReversibleClientScanner for the specified table.
ClientSmallScanner(org.apache.hadoop.conf.Configuration conf, Scan scan, TableName tableName, ClusterConnection connection, RpcRetryingCallerFactory rpcFactory, RpcControllerFactory controllerFactory, ExecutorService pool, int primaryOperationTimeout) Create a new ShortClientScanner for the specified table.
CoprocessorHConnection(ClusterConnection delegate, HRegionServer server) Deprecated. delegate is not used
FlushRegionCallable(ClusterConnection connection, RpcControllerFactory rpcControllerFactory, HRegionInfo regionInfo, boolean writeFlushWalMarker)
FlushRegionCallable(ClusterConnection connection, RpcControllerFactory rpcControllerFactory, TableName tableName, byte[] regionName, byte[] regionStartKey, boolean writeFlushWalMarker)
HRegionLocator(TableName tableName, ClusterConnection connection)
HTable(ClusterConnection conn, BufferedMutatorParams params) For internal testing.
HTable(TableName tableName, ClusterConnection connection, ConnectionConfiguration tableConfig, RpcRetryingCallerFactory rpcCallerFactory, RpcControllerFactory rpcControllerFactory, ExecutorService pool) Creates an object to access a HBase table.
RegionAdminServiceCallable(ClusterConnection connection, RpcControllerFactory rpcControllerFactory, HRegionLocation location, TableName tableName, byte[] row)
RegionAdminServiceCallable(ClusterConnection connection, RpcControllerFactory rpcControllerFactory, HRegionLocation location, TableName tableName, byte[] row, int replicaId)
RegionAdminServiceCallable(ClusterConnection connection, RpcControllerFactory rpcControllerFactory, TableName tableName, byte[] row)
ReversedClientScanner(org.apache.hadoop.conf.Configuration conf, Scan scan, TableName tableName, ClusterConnection connection, RpcRetryingCallerFactory rpcFactory, RpcControllerFactory controllerFactory, ExecutorService pool, int primaryOperationTimeout) Create a new ReversibleClientScanner for the specified table Note that the passed Scan's start row maybe changed.
ReversedScannerCallable(ClusterConnection connection, TableName tableName, Scan scan, ScanMetrics scanMetrics, byte[] locateStartRow) Deprecated. use ReversedScannerCallable.ReversedScannerCallable(ClusterConnection, TableName, Scan, ScanMetrics, byte[], RpcControllerFactory )
ReversedScannerCallable(ClusterConnection connection, TableName tableName, Scan scan, ScanMetrics scanMetrics, byte[] locateStartRow, RpcControllerFactory rpcFactory)
ReversedScannerCallable(ClusterConnection connection, TableName tableName, Scan scan, ScanMetrics scanMetrics, byte[] locateStartRow, RpcControllerFactory rpcFactory, int replicaId)
RpcRetryingCallerWithReadReplicas(RpcControllerFactory rpcControllerFactory, TableName tableName, ClusterConnection cConnection, Get get, ExecutorService pool, int retries, int callTimeout, int timeBeforeReplicas)
ScannerCallable(ClusterConnection connection, TableName tableName, Scan scan, ScanMetrics scanMetrics, RpcControllerFactory rpcControllerFactory)
ScannerCallable(ClusterConnection connection, TableName tableName, Scan scan, ScanMetrics scanMetrics, RpcControllerFactory rpcControllerFactory, int id)

Uses of ClusterConnection in org.apache.hadoop.hbase.ipc

Constructors in org.apache.hadoop.hbase.ipc with parameters of type ClusterConnection

Constructor and Description
MasterCoprocessorRpcChannel(ClusterConnection conn)
RegionCoprocessorRpcChannel(ClusterConnection conn, TableName table, byte[] row)
RegionServerCoprocessorRpcChannel(ClusterConnection conn, ServerName serverName)

Uses of ClusterConnection in org.apache.hadoop.hbase.master

Methods in org.apache.hadoop.hbase.master with parameters of type ClusterConnection

Modifier and Type	Method and Description
static void	ServerManager.closeRegionSilentlyAndWait(ClusterConnection connection, ServerName server, HRegionInfo region, long timeout) Contacts a region server and waits up to timeout ms to close the region.

Uses of ClusterConnection in org.apache.hadoop.hbase.regionserver

Fields in org.apache.hadoop.hbase.regionserver declared as ClusterConnection

Modifier and Type	Field and Description
protected ClusterConnection	HRegionServer.clusterConnection Cluster connection to be shared by services.

Methods in org.apache.hadoop.hbase.regionserver that return ClusterConnection

Modifier and Type	Method and Description
protected ClusterConnection	HRegionServer.createClusterConnection() Create a 'smarter' HConnection, one that is capable of by-passing RPC if the request is to the local server.
ClusterConnection	HRegionServer.getConnection()

Uses of ClusterConnection in org.apache.hadoop.hbase.regionserver.handler

Constructors in org.apache.hadoop.hbase.regionserver.handler with parameters of type ClusterConnection

Constructor and Description
RegionReplicaFlushHandler(Server server, ClusterConnection connection, RpcRetryingCallerFactory rpcRetryingCallerFactory, RpcControllerFactory rpcControllerFactory, int operationTimeout, HRegion region)