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

Constructor Summary

Constructors

Modifier	Constructor and Description
private	TableCache()

Method Summary

Modifier and Type	Method and Description
void	clearCompletedRequests(Optional<HRegionLocation> location)
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<HRegionLocation> future, Optional<HRegionLocation> location)

Methods inherited from class java.lang.Object

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

Field Detail

cache

public final ConcurrentNavigableMap<byte[],HRegionLocation> cache

pendingRequests

public final Set<AsyncNonMetaRegionLocator.LocateRequest> pendingRequests

allRequests

public final Map<AsyncNonMetaRegionLocator.LocateRequest,CompletableFuture<HRegionLocation>> 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(Optional<HRegionLocation> location)

tryComplete

private boolean tryComplete(AsyncNonMetaRegionLocator.LocateRequest req,
                            CompletableFuture<HRegionLocation> future,
                            Optional<HRegionLocation> location)