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 and Description
private Map<AsyncNonMetaRegionLocator.LocateRequest,CompletableFuture<RegionLocations>>	allRequests
private ConcurrentNavigableMap<byte[],RegionLocations>	cache
private Set<AsyncNonMetaRegionLocator.LocateRequest>	pendingRequests

Constructor Summary

Constructors

Modifier	Constructor and Description
private	TableCache()

Method Summary

Modifier and Type	Method and Description
void	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)

Methods inherited from class java.lang.Object

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

Field Detail

cache

private final ConcurrentNavigableMap<byte[],RegionLocations> cache

pendingRequests

private final Set<AsyncNonMetaRegionLocator.LocateRequest> pendingRequests

allRequests

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

Constructor Detail

TableCache

private TableCache()

Method Detail

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 void clearCompletedRequests(RegionLocations locations)

tryComplete

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