Package org.apache.hadoop.hbase.client

Class AsyncNonMetaRegionLocator

java.lang.Object

org.apache.hadoop.hbase.client.AsyncNonMetaRegionLocator

@Private
class AsyncNonMetaRegionLocator
extends Object

The asynchronous locator for regions other than meta.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	AsyncNonMetaRegionLocator.LocateRequest
private static final class	AsyncNonMetaRegionLocator.RegionLocationsFutureResult
private static final class	AsyncNonMetaRegionLocator.TableCache

Field Summary

Fields

Modifier and Type	Field	Description
private final ConcurrentMap<TableName,AsyncNonMetaRegionLocator.TableCache>	cache
private final AsyncConnectionImpl	conn
private static final int	DEFAULT_LOCATE_PREFETCH_LIMIT
private static final int	DEFAULT_MAX_CONCURRENT_LOCATE_REQUEST_PER_TABLE
(package private) static String	LOCATE_PREFETCH_LIMIT
private final int	locatePrefetchLimit
private static final org.slf4j.Logger	LOG
(package private) static final String	MAX_CONCURRENT_LOCATE_REQUEST_PER_TABLE
private final int	maxConcurrentLocateRequestPerTable
private CatalogReplicaMode	metaReplicaMode
private CatalogReplicaLoadBalanceSelector	metaReplicaSelector
private final org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer	retryTimer

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
(package private) void	addLocationToCache(HRegionLocation loc)
(package private) void	clearCache()
(package private) void	clearCache(ServerName serverName)
(package private) void	clearCache(TableName tableName)
private void	complete(TableName tableName, AsyncNonMetaRegionLocator.LocateRequest req, RegionLocations locs, Throwable error)
private HRegionLocation	getCachedLocation(HRegionLocation loc)
(package private) RegionLocations	getCachedLocation(TableName tableName, byte[] startKey)
private org.apache.hbase.thirdparty.io.netty.util.TimerTask	getInvalidateMetaCacheTask(long metaCacheInvalidateInterval)
(package private) int	getNumberOfCachedRegionLocations(TableName tableName)
(package private) RegionLocations	getRegionLocationInCache(TableName tableName, byte[] row)
(package private) CompletableFuture<RegionLocations>	getRegionLocations(TableName tableName, byte[] row, int replicaId, RegionLocateType locateType, boolean reload)
private CompletableFuture<RegionLocations>	getRegionLocationsInternal(TableName tableName, byte[] row, int replicaId, RegionLocateType locateType, boolean reload)
private AsyncNonMetaRegionLocator.TableCache	getTableCache(TableName tableName)
private void	invalidateCache(CompletableFuture<Void> future, Iterator<TableName> tbnIter, AsyncAdmin admin)
private CompletableFuture<Void>	invalidateTableCache()
private RegionLocations	locateInCache(AsyncNonMetaRegionLocator.TableCache tableCache, byte[] row, int replicaId, RegionLocateType locateType)
private void	locateInMeta(TableName tableName, AsyncNonMetaRegionLocator.LocateRequest req)
private RegionLocations	locateRowBeforeInCache(AsyncNonMetaRegionLocator.TableCache tableCache, byte[] row, int replicaId)
private RegionLocations	locateRowInCache(AsyncNonMetaRegionLocator.TableCache tableCache, byte[] row, int replicaId)
private boolean	onScanNext(TableName tableName, AsyncNonMetaRegionLocator.LocateRequest req, Result result)
private void	recordCacheHit()
private void	recordCacheMiss()
private void	recordClearRegionCache()
private void	removeLocationFromCache(HRegionLocation loc)
(package private) void	updateCachedLocationOnError(HRegionLocation loc, Throwable exception)
private void	updateMetaReplicaSelector(HRegionLocation loc)

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

MAX_CONCURRENT_LOCATE_REQUEST_PER_TABLE

static final String MAX_CONCURRENT_LOCATE_REQUEST_PER_TABLE

See Also:

• Constant Field Values

DEFAULT_MAX_CONCURRENT_LOCATE_REQUEST_PER_TABLE

private static final int DEFAULT_MAX_CONCURRENT_LOCATE_REQUEST_PER_TABLE

See Also:

• Constant Field Values

LOCATE_PREFETCH_LIMIT

static String LOCATE_PREFETCH_LIMIT

DEFAULT_LOCATE_PREFETCH_LIMIT

private static final int DEFAULT_LOCATE_PREFETCH_LIMIT

See Also:

• Constant Field Values

conn

private final AsyncConnectionImpl conn

maxConcurrentLocateRequestPerTable

private final int maxConcurrentLocateRequestPerTable

locatePrefetchLimit

private final int locatePrefetchLimit

metaReplicaMode

private CatalogReplicaMode metaReplicaMode

metaReplicaSelector

private CatalogReplicaLoadBalanceSelector metaReplicaSelector

cache

private final ConcurrentMap<TableName,AsyncNonMetaRegionLocator.TableCache> cache

retryTimer

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

Constructor Details

AsyncNonMetaRegionLocator

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

Method Details

getTableCache

private AsyncNonMetaRegionLocator.TableCache getTableCache(TableName tableName)

complete

private void complete(TableName tableName,
 AsyncNonMetaRegionLocator.LocateRequest req,
 RegionLocations locs,
 Throwable error)

onScanNext

private boolean onScanNext(TableName tableName,
 AsyncNonMetaRegionLocator.LocateRequest req,
 Result result)

recordCacheHit

private void recordCacheHit()

recordCacheMiss

private void recordCacheMiss()

locateRowInCache

private RegionLocations locateRowInCache(AsyncNonMetaRegionLocator.TableCache tableCache,
 byte[] row,
 int replicaId)

locateRowBeforeInCache

private RegionLocations locateRowBeforeInCache(AsyncNonMetaRegionLocator.TableCache tableCache,
 byte[] row,
 int replicaId)

locateInMeta

private void locateInMeta(TableName tableName,
 AsyncNonMetaRegionLocator.LocateRequest req)

locateInCache

private RegionLocations locateInCache(AsyncNonMetaRegionLocator.TableCache tableCache,
 byte[] row,
 int replicaId,
 RegionLocateType locateType)

getRegionLocationsInternal

private CompletableFuture<RegionLocations> getRegionLocationsInternal(TableName tableName,
 byte[] row,
 int replicaId,
 RegionLocateType locateType,
 boolean reload)

getRegionLocations

CompletableFuture<RegionLocations> getRegionLocations(TableName tableName,
 byte[] row,
 int replicaId,
 RegionLocateType locateType,
 boolean reload)

recordClearRegionCache

private void recordClearRegionCache()

removeLocationFromCache

private void removeLocationFromCache(HRegionLocation loc)

updateMetaReplicaSelector

private void updateMetaReplicaSelector(HRegionLocation loc)

addLocationToCache

void addLocationToCache(HRegionLocation loc)

getCachedLocation

RegionLocations getCachedLocation(TableName tableName,
 byte[] startKey)

getCachedLocation

private HRegionLocation getCachedLocation(HRegionLocation loc)

updateCachedLocationOnError

void updateCachedLocationOnError(HRegionLocation loc,
 Throwable exception)

clearCache

void clearCache(TableName tableName)

clearCache

void clearCache()

clearCache

void clearCache(ServerName serverName)

getRegionLocationInCache

RegionLocations getRegionLocationInCache(TableName tableName,
 byte[] row)

getNumberOfCachedRegionLocations

int getNumberOfCachedRegionLocations(TableName tableName)

getInvalidateMetaCacheTask

private org.apache.hbase.thirdparty.io.netty.util.TimerTask getInvalidateMetaCacheTask(long metaCacheInvalidateInterval)

invalidateTableCache

private CompletableFuture<Void> invalidateTableCache()

invalidateCache

private void invalidateCache(CompletableFuture<Void> future,
 Iterator<TableName> tbnIter,
 AsyncAdmin admin)