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 AsyncConnectionImpl	conn
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()
(package private) void	clearCache(ServerName serverName)
(package private) void	clearCache(TableName tableName)
(package private) AsyncNonMetaRegionLocator	getNonMetaRegionLocator()
(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)
(package private) static List<String>	getRegionNames(HRegionLocation location)
(package private) static List<String>	getRegionNames(RegionLocations locs)
private boolean	isMeta(TableName tableName)
private <T> CompletableFuture<T>	tracedLocationFuture(Supplier<CompletableFuture<T>> action, Function<T,List<String>> getRegionNames, Supplier<io.opentelemetry.api.trace.Span> spanSupplier)
(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

conn

private final AsyncConnectionImpl conn

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)

tracedLocationFuture

private <T> CompletableFuture<T> tracedLocationFuture(Supplier<CompletableFuture<T>> action,
                                                      Function<T,List<String>> getRegionNames,
                                                      Supplier<io.opentelemetry.api.trace.Span> spanSupplier)

getRegionNames

static List<String> getRegionNames(RegionLocations locs)

getRegionNames

static List<String> getRegionNames(HRegionLocation location)

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)

clearCache

void clearCache(ServerName serverName)

clearCache

void clearCache()

getNonMetaRegionLocator

AsyncNonMetaRegionLocator getNonMetaRegionLocator()