Package org.apache.hadoop.hbase.client

Class AsyncNonMetaRegionLocator.TableCache

java.lang.Object

org.apache.hadoop.hbase.client.AsyncNonMetaRegionLocator.TableCache

Enclosing class:

AsyncNonMetaRegionLocator

private static final class AsyncNonMetaRegionLocator.TableCache
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final Map<AsyncNonMetaRegionLocator.LocateRequest,CompletableFuture<RegionLocations>>	allRequests
private final Set<AsyncNonMetaRegionLocator.LocateRequest>	pendingRequests
private final AsyncRegionLocationCache	regionLocationCache

Constructor Summary

Constructors

Constructor	Description
TableCache(TableName tableName)

Method Summary

Modifier and Type	Method	Description
List<AsyncNonMetaRegionLocator.RegionLocationsFutureResult>	clearCompletedRequests(RegionLocations locations)
Optional<AsyncNonMetaRegionLocator.LocateRequest>	getCandidate()
boolean	hasQuota(int max)
boolean	isPending(AsyncNonMetaRegionLocator.LocateRequest req)
void	send(AsyncNonMetaRegionLocator.LocateRequest req)
private boolean	tryComplete(AsyncNonMetaRegionLocator.LocateRequest req, CompletableFuture<RegionLocations> future, RegionLocations locations, List<AsyncNonMetaRegionLocator.RegionLocationsFutureResult> futureResultList)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

pendingRequests

private final Set<AsyncNonMetaRegionLocator.LocateRequest> pendingRequests

allRequests

private final Map<AsyncNonMetaRegionLocator.LocateRequest,CompletableFuture<RegionLocations>> allRequests

regionLocationCache

private final AsyncRegionLocationCache regionLocationCache

Constructor Details

TableCache

public TableCache(TableName tableName)

Method Details

hasQuota

public boolean hasQuota(int max)

isPending

public boolean isPending(AsyncNonMetaRegionLocator.LocateRequest req)

send

public void send(AsyncNonMetaRegionLocator.LocateRequest req)

getCandidate

public Optional<AsyncNonMetaRegionLocator.LocateRequest> getCandidate()

clearCompletedRequests

public List<AsyncNonMetaRegionLocator.RegionLocationsFutureResult> clearCompletedRequests(RegionLocations locations)

tryComplete

private boolean tryComplete(AsyncNonMetaRegionLocator.LocateRequest req,
 CompletableFuture<RegionLocations> future,
 RegionLocations locations,
 List<AsyncNonMetaRegionLocator.RegionLocationsFutureResult> futureResultList)