Package org.apache.hadoop.hbase.client

Class ShortCircuitConnectionRegistry

java.lang.Object

org.apache.hadoop.hbase.client.ShortCircuitConnectionRegistry

All Implemented Interfaces:

Closeable, AutoCloseable, ConnectionRegistry

@Private
class ShortCircuitConnectionRegistry
extends Object
implements ConnectionRegistry

A ConnectionRegistry implementation used at server side, where we could use the ConnectionRegistryEndpoint directly, without any rpcs.

Field Summary

Fields

Modifier and Type	Field	Description
private final ConnectionRegistryEndpoint	endpoint

Constructor Summary

Constructors

Constructor	Description
ShortCircuitConnectionRegistry(ConnectionRegistryEndpoint endpoint)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes this instance and releases any system resources associated with it
CompletableFuture<ServerName>	getActiveMaster()	Get the address of active HMaster.
CompletableFuture<String>	getClusterId()	Should only be called once.
String	getConnectionString()	Return the connection string associated with this registry instance.
CompletableFuture<RegionLocations>	getMetaRegionLocations()	Get the location of meta region(s).

Methods inherited from class java.lang.Object

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

Field Details

endpoint

private final ConnectionRegistryEndpoint endpoint

Constructor Details

ShortCircuitConnectionRegistry

public ShortCircuitConnectionRegistry(ConnectionRegistryEndpoint endpoint)

Method Details

getMetaRegionLocations

public CompletableFuture<RegionLocations> getMetaRegionLocations()

Description copied from interface: ConnectionRegistry

Get the location of meta region(s).

Specified by:

getMetaRegionLocations in interface ConnectionRegistry

getClusterId

public CompletableFuture<String> getClusterId()

Description copied from interface: ConnectionRegistry

Should only be called once.

The upper layer should store this value somewhere as it will not be change any more.

Specified by:

getClusterId in interface ConnectionRegistry

getActiveMaster

public CompletableFuture<ServerName> getActiveMaster()

Description copied from interface: ConnectionRegistry

Get the address of active HMaster.

Specified by:

getActiveMaster in interface ConnectionRegistry

getConnectionString

public String getConnectionString()

Description copied from interface: ConnectionRegistry

Return the connection string associated with this registry instance. This value is informational, used for annotating traces. Values returned may not be valid for establishing a working cluster connection.

Specified by:

getConnectionString in interface ConnectionRegistry

close

public void close()

Description copied from interface: ConnectionRegistry

Closes this instance and releases any system resources associated with it

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface ConnectionRegistry