org.apache.hadoop.hbase.client

Class ConnectionUtils.ShortCircuitingClusterConnection

java.lang.Object

org.apache.hadoop.hbase.client.ConnectionImplementation

org.apache.hadoop.hbase.client.ConnectionUtils.ShortCircuitingClusterConnection

All Implemented Interfaces:

Closeable, AutoCloseable, Abortable, ClusterConnection, Connection

Enclosing class:

ConnectionUtils

public static class ConnectionUtils.ShortCircuitingClusterConnection
extends ConnectionImplementation

A ClusterConnection that will short-circuit RPC making direct invocations against the localhost if the invocation target is 'this' server; save on network and protobuf invocations.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.client.ConnectionImplementation

ConnectionImplementation.MasterServiceState, ConnectionImplementation.ServerErrorTracker

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface	localHostAdmin
private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface	localHostClient
private ServerName	serverName

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

clusterId, clusterStatusListener, masterServiceState, RETRIES_BY_SERVER_KEY, rpcTimeout, user

Fields inherited from interface org.apache.hadoop.hbase.client.ClusterConnection

HBASE_CLIENT_CONNECTION_IMPL

Constructor Summary

Constructors

Modifier	Constructor and Description
private	ShortCircuitingClusterConnection(org.apache.hadoop.conf.Configuration conf, ExecutorService pool, User user, ServerName serverName, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface admin, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface client)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface	getAdmin(ServerName sn) Establishes a connection to the region server at the specified address.
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface	getClient(ServerName sn) Establishes a connection to the region server at the specified address, and returns a region client protocol.
MasterKeepAliveConnection	getMaster() Returns a MasterKeepAliveConnection to the active master

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

abort, cacheLocation, clearCaches, clearRegionCache, clearRegionCache, clearRegionCache, close, deleteCachedRegionLocation, finalize, getAdmin, getAdminForMaster, getAsyncProcess, getBackoffPolicy, getBufferedMutator, getBufferedMutator, getCachedLocation, getConfiguration, getConnectionConfiguration, getConnectionMetrics, getCurrentBatchPool, getCurrentMetaLookupPool, getCurrentNrHRS, getHbck, getHbck, getNewRpcRetryingCallerFactory, getNonceGenerator, getNumberOfCachedRegionLocations, getRegionLocation, getRegionLocator, getRpcClient, getRpcControllerFactory, getRpcRetryingCallerFactory, getStatisticsTracker, getTable, getTableBuilder, getTableState, hasCellBlockSupport, injectNonceGeneratorForTesting, isAborted, isClosed, isMasterRunning, isTableAvailable, isTableDisabled, isTableEnabled, locateRegion, locateRegion, locateRegion, locateRegion, locateRegions, locateRegions, releaseMaster, relocateRegion, relocateRegion, retrieveClusterId, setUseMetaReplicas, toString, updateCachedLocation, updateCachedLocations

Methods inherited from class java.lang.Object

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

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

getTable

Field Detail

serverName

private final ServerName serverName

localHostAdmin

private final org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface localHostAdmin

localHostClient

private final org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface localHostClient

Constructor Detail

ShortCircuitingClusterConnection

private ShortCircuitingClusterConnection(org.apache.hadoop.conf.Configuration conf,
                                         ExecutorService pool,
                                         User user,
                                         ServerName serverName,
                                         org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface admin,
                                         org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface client)
                                  throws IOException

Throws:

IOException

Method Detail

getAdmin

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface getAdmin(ServerName sn)
                                                                                                      throws IOException

Description copied from interface: ClusterConnection

Establishes a connection to the region server at the specified address.

Specified by:

getAdmin in interface ClusterConnection

Overrides:

getAdmin in class ConnectionImplementation

Returns:

proxy for HRegionServer

Throws:

IOException - if a remote or network exception occurs

getClient

public org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface getClient(ServerName sn)
                                                                                                         throws IOException

Description copied from interface: ClusterConnection

Establishes a connection to the region server at the specified address, and returns a region client protocol.

Specified by:

getClient in interface ClusterConnection

Overrides:

getClient in class ConnectionImplementation

Returns:

ClientProtocol proxy for RegionServer

Throws:

IOException - if a remote or network exception occurs

getMaster

public MasterKeepAliveConnection getMaster()
                                    throws IOException

Description copied from interface: ClusterConnection

Returns a MasterKeepAliveConnection to the active master

Specified by:

getMaster in interface ClusterConnection

Overrides:

getMaster in class ConnectionImplementation

Throws:

IOException