org.apache.hadoop.hbase.client

Class ZKAsyncRegistry

java.lang.Object

org.apache.hadoop.hbase.client.ZKAsyncRegistry

All Implemented Interfaces:

Closeable, AutoCloseable, AsyncRegistry

@InterfaceAudience.Private
class ZKAsyncRegistry
extends Object
implements AsyncRegistry

Zookeeper based registry implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static interface	ZKAsyncRegistry.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
ZKAsyncRegistry(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
private <T> CompletableFuture<T>	getAndConvert(String path, ZKAsyncRegistry.Converter<T> converter)
CompletableFuture<String>	getClusterId() Should only be called once.
private static String	getClusterId(byte[] data)
CompletableFuture<ServerName>	getMasterAddress() Get the address of HMaster.
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)
CompletableFuture<RegionLocations>	getMetaRegionLocation() Get the location of meta region.
private void	getMetaRegionLocation(CompletableFuture<RegionLocations> future, List<String> metaReplicaZNodes)
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, 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

ZKAsyncRegistry

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

Method Detail

getAndConvert

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

getClusterId

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

Throws:

DeserializationException

getClusterId

public CompletableFuture<String> getClusterId()

Description copied from interface: AsyncRegistry

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 AsyncRegistry

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

getMetaRegionLocation

public CompletableFuture<RegionLocations> getMetaRegionLocation()

Description copied from interface: AsyncRegistry

Get the location of meta region.

Specified by:

getMetaRegionLocation in interface AsyncRegistry

getMasterProto

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

Throws:

IOException

getMasterAddress

public CompletableFuture<ServerName> getMasterAddress()

Description copied from interface: AsyncRegistry

Get the address of HMaster.

Specified by:

getMasterAddress in interface AsyncRegistry

close

public void close()

Description copied from interface: AsyncRegistry

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 AsyncRegistry