org.apache.hadoop.hbase.client

Class ZKConnectionRegistry

java.lang.Object

org.apache.hadoop.hbase.client.ZKConnectionRegistry

All Implemented Interfaces:

Closeable, AutoCloseable, ConnectionRegistry

@InterfaceAudience.Private
class ZKConnectionRegistry
extends Object
implements ConnectionRegistry

Zookeeper based registry implementation.

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG
private ReadOnlyZKClient	zk
private ZNodePaths	znodePaths

Constructor Summary

Constructors

Constructor and Description
ZKConnectionRegistry(org.apache.hadoop.conf.Configuration conf)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

zk

private final ReadOnlyZKClient zk

znodePaths

private final ZNodePaths znodePaths

Constructor Detail

ZKConnectionRegistry

ZKConnectionRegistry(org.apache.hadoop.conf.Configuration conf)

Method Detail

getAndConvert

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

getClusterId

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

Throws:

DeserializationException

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

getZKClient

ReadOnlyZKClient getZKClient()

getMetaProto

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

Throws:

IOException

tryComplete

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

getStateAndServerName

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

getMetaRegionLocation

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

getMetaRegionLocations

public CompletableFuture<RegionLocations> getMetaRegionLocations()

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

Throws:

IOException

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 Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ConnectionRegistry