Package org.apache.hadoop.hbase.client

Class AsyncRegionLocator

java.lang.Object

org.apache.hadoop.hbase.client.AsyncRegionLocator

@Private
class AsyncRegionLocator
extends Object

The asynchronous region locator.

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
(package private) void	clearCache()
(package private) void	clearCache(ServerName serverName)
(package private) void	clearCache(TableName tableName)
(package private) AsyncNonMetaRegionLocator	getNonMetaRegionLocator()
(package private) int	getNumberOfCachedRegionLocations(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) RegionLocations	getRegionLocationInCache(TableName tableName, byte[] row)
(package private) CompletableFuture<RegionLocations>	getRegionLocations(TableName tableName, byte[] row, RegionLocateType type, boolean reload, long timeoutNs)
private static List<String>	getRegionNames(HRegionLocation location)
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 Details

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 Details

AsyncRegionLocator

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

Method Details

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

private static List<String> getRegionNames(RegionLocations locs)

getRegionNames

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

getRegionLocationInCache

RegionLocations getRegionLocationInCache(TableName tableName,
 byte[] row)

getNumberOfCachedRegionLocations

int getNumberOfCachedRegionLocations(TableName tableName)