Package org.apache.hadoop.hbase.client

Class ZKConnectionRegistry

java.lang.Object

org.apache.hadoop.hbase.client.ZKConnectionRegistry

All Implemented Interfaces:

Closeable, AutoCloseable, ConnectionRegistry

@Deprecated
@LimitedPrivate("Configuration")
class ZKConnectionRegistry
extends Object
implements ConnectionRegistry

Deprecated.

As of 2.6.0, replaced by RpcConnectionRegistry, which is the default connection mechanism as of 3.0.0. Expected to be removed in 4.0.0.

Zookeeper based registry implementation.

See Also:

• HBASE-23324 and its parent ticket for details.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static interface	ZKConnectionRegistry.Converter<T>	Deprecated.

Field Summary

Fields

Modifier and Type	Field	Description
private final org.apache.hadoop.conf.Configuration	conf	Deprecated.
static final int	DEFAULT_ZK_REGISTRY_ASYNC_GET_TIMEOUT	Deprecated.
private static final org.slf4j.Logger	LOG	Deprecated.
private static boolean	NEEDS_LOG_WARN	Deprecated.
private static final Object	WARN_LOCK	Deprecated.
private final ReadOnlyZKClient	zk	Deprecated.
static final String	ZK_REGISTRY_ASYNC_GET_TIMEOUT	Deprecated.
private final int	zkRegistryAsyncTimeout	Deprecated.
private final ZNodePaths	znodePaths	Deprecated.

Constructor Summary

Constructors

Constructor	Description
ZKConnectionRegistry(org.apache.hadoop.conf.Configuration conf, User ignored)	Deprecated.

Method Summary

Modifier and Type	Method	Description
void	close()	Deprecated. Closes this instance and releases any system resources associated with it
CompletableFuture<ServerName>	getActiveMaster()	Deprecated. Get the address of active HMaster.
private <T> CompletableFuture<T>	getAndConvert(String path, ZKConnectionRegistry.Converter<T> converter)	Deprecated.
CompletableFuture<String>	getClusterId()	Deprecated. Should only be called once.
private static String	getClusterId(byte[] data)	Deprecated.
String	getConnectionString()	Deprecated. Return the connection string associated with this registry instance.
private static org.apache.hadoop.hbase.shaded.protobuf.generated.ZooKeeperProtos.Master	getMasterProto(byte[] data)	Deprecated.
private static org.apache.hadoop.hbase.shaded.protobuf.generated.ZooKeeperProtos.MetaRegionServer	getMetaProto(byte[] data)	Deprecated.
private void	getMetaRegionLocation(CompletableFuture<RegionLocations> future, List<String> metaReplicaZNodes)	Deprecated.
CompletableFuture<RegionLocations>	getMetaRegionLocations()	Deprecated. Get the location of meta region(s).
private Pair<RegionState.State,ServerName>	getStateAndServerName(org.apache.hadoop.hbase.shaded.protobuf.generated.ZooKeeperProtos.MetaRegionServer proto)	Deprecated.
(package private) ReadOnlyZKClient	getZKClient()	Deprecated.
private static void	tryComplete(org.apache.commons.lang3.mutable.MutableInt remaining, HRegionLocation[] locs, CompletableFuture<RegionLocations> future)	Deprecated.

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

Deprecated.

WARN_LOCK

private static final Object WARN_LOCK

Deprecated.

NEEDS_LOG_WARN

private static volatile boolean NEEDS_LOG_WARN

Deprecated.

zk

private final ReadOnlyZKClient zk

Deprecated.

znodePaths

private final ZNodePaths znodePaths

Deprecated.

conf

private final org.apache.hadoop.conf.Configuration conf

Deprecated.

zkRegistryAsyncTimeout

private final int zkRegistryAsyncTimeout

Deprecated.

ZK_REGISTRY_ASYNC_GET_TIMEOUT

public static final String ZK_REGISTRY_ASYNC_GET_TIMEOUT

Deprecated.

See Also:

• Constant Field Values

DEFAULT_ZK_REGISTRY_ASYNC_GET_TIMEOUT

public static final int DEFAULT_ZK_REGISTRY_ASYNC_GET_TIMEOUT

Deprecated.

See Also:

• Constant Field Values

Constructor Details

ZKConnectionRegistry

ZKConnectionRegistry(org.apache.hadoop.conf.Configuration conf,
 User ignored)

Deprecated.

Method Details

getAndConvert

private <T> CompletableFuture<T> getAndConvert(String path,
 ZKConnectionRegistry.Converter<T> converter)

Deprecated.

getClusterId

private static String getClusterId(byte[] data)
                            throws DeserializationException

Deprecated.

Throws:

DeserializationException

getClusterId

public CompletableFuture<String> getClusterId()

Deprecated.

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

getZKClient

ReadOnlyZKClient getZKClient()

Deprecated.

getMetaProto

private static org.apache.hadoop.hbase.shaded.protobuf.generated.ZooKeeperProtos.MetaRegionServer getMetaProto(byte[] data)
                                                                                                        throws IOException

Deprecated.

Throws:

IOException

tryComplete

private static void tryComplete(org.apache.commons.lang3.mutable.MutableInt remaining,
 HRegionLocation[] locs,
 CompletableFuture<RegionLocations> future)

Deprecated.

getStateAndServerName

private Pair<RegionState.State,ServerName> getStateAndServerName(org.apache.hadoop.hbase.shaded.protobuf.generated.ZooKeeperProtos.MetaRegionServer proto)

Deprecated.

getMetaRegionLocation

private void getMetaRegionLocation(CompletableFuture<RegionLocations> future,
 List<String> metaReplicaZNodes)

Deprecated.

getMetaRegionLocations

public CompletableFuture<RegionLocations> getMetaRegionLocations()

Deprecated.

Description copied from interface: ConnectionRegistry

Get the location of meta region(s).

Specified by:

getMetaRegionLocations in interface ConnectionRegistry

getMasterProto

private static org.apache.hadoop.hbase.shaded.protobuf.generated.ZooKeeperProtos.Master getMasterProto(byte[] data)
                                                                                                throws IOException

Deprecated.

Throws:

IOException

getActiveMaster

public CompletableFuture<ServerName> getActiveMaster()

Deprecated.

Description copied from interface: ConnectionRegistry

Get the address of active HMaster.

Specified by:

getActiveMaster in interface ConnectionRegistry

getConnectionString

public String getConnectionString()

Deprecated.

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()

Deprecated.

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