org.apache.hadoop.hbase.client

Class AsyncRegionLocator

java.lang.Object

org.apache.hadoop.hbase.client.AsyncRegionLocator

@InterfaceAudience.Private
class AsyncRegionLocator
extends Object

The asynchronous region locator.

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG
private AsyncMetaRegionLocator	metaRegionLocator
private AsyncNonMetaRegionLocator	nonMetaRegionLocator
private org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer	retryTimer

Constructor Summary

Constructors

Constructor and Description
AsyncRegionLocator(AsyncConnectionImpl conn, org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer retryTimer)

Method Summary

Modifier and Type	Method and Description
(package private) void	clearCache(TableName tableName)
(package private) CompletableFuture<HRegionLocation>	getRegionLocation(TableName tableName, byte[] row, int replicaId, RegionLocateType type, boolean reload, long timeoutNs)
(package private) CompletableFuture<HRegionLocation>	getRegionLocation(TableName tableName, byte[] row, int replicaId, RegionLocateType type, long timeoutNs)
(package private) CompletableFuture<HRegionLocation>	getRegionLocation(TableName tableName, byte[] row, RegionLocateType type, boolean reload, long timeoutNs)
(package private) CompletableFuture<HRegionLocation>	getRegionLocation(TableName tableName, byte[] row, RegionLocateType type, long timeoutNs)
(package private) CompletableFuture<RegionLocations>	getRegionLocations(TableName tableName, byte[] row, RegionLocateType type, boolean reload, long timeoutNs)
private boolean	isMeta(TableName tableName)
(package private) void	updateCachedLocationOnError(HRegionLocation loc, Throwable exception)
private <T> CompletableFuture<T>	withTimeout(CompletableFuture<T> future, long timeoutNs, Supplier<String> timeoutMsg)

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

retryTimer

private final org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer retryTimer

metaRegionLocator

private final AsyncMetaRegionLocator metaRegionLocator

nonMetaRegionLocator

private final AsyncNonMetaRegionLocator nonMetaRegionLocator

Constructor Detail

AsyncRegionLocator

AsyncRegionLocator(AsyncConnectionImpl conn,
                   org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer retryTimer)

Method Detail

withTimeout

private <T> CompletableFuture<T> withTimeout(CompletableFuture<T> future,
                                             long timeoutNs,
                                             Supplier<String> timeoutMsg)

isMeta

private boolean isMeta(TableName tableName)

getRegionLocations

CompletableFuture<RegionLocations> getRegionLocations(TableName tableName,
                                                      byte[] row,
                                                      RegionLocateType type,
                                                      boolean reload,
                                                      long timeoutNs)

getRegionLocation

CompletableFuture<HRegionLocation> getRegionLocation(TableName tableName,
                                                     byte[] row,
                                                     int replicaId,
                                                     RegionLocateType type,
                                                     boolean reload,
                                                     long timeoutNs)

getRegionLocation

CompletableFuture<HRegionLocation> getRegionLocation(TableName tableName,
                                                     byte[] row,
                                                     int replicaId,
                                                     RegionLocateType type,
                                                     long timeoutNs)

getRegionLocation

CompletableFuture<HRegionLocation> getRegionLocation(TableName tableName,
                                                     byte[] row,
                                                     RegionLocateType type,
                                                     boolean reload,
                                                     long timeoutNs)

getRegionLocation

CompletableFuture<HRegionLocation> getRegionLocation(TableName tableName,
                                                     byte[] row,
                                                     RegionLocateType type,
                                                     long timeoutNs)

updateCachedLocationOnError

void updateCachedLocationOnError(HRegionLocation loc,
                                 Throwable exception)

clearCache

void clearCache(TableName tableName)