private static final class AsyncNonMetaRegionLocator.TableCache extends Object
Modifier and Type | Field and Description |
---|---|
Map<AsyncNonMetaRegionLocator.LocateRequest,CompletableFuture<HRegionLocation>> |
allRequests |
ConcurrentNavigableMap<byte[],HRegionLocation> |
cache |
Set<AsyncNonMetaRegionLocator.LocateRequest> |
pendingRequests |
Modifier | Constructor and Description |
---|---|
private |
TableCache() |
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) |
public final ConcurrentNavigableMap<byte[],HRegionLocation> cache
public final Set<AsyncNonMetaRegionLocator.LocateRequest> pendingRequests
public final Map<AsyncNonMetaRegionLocator.LocateRequest,CompletableFuture<HRegionLocation>> allRequests
private TableCache()
public boolean hasQuota(int max)
public boolean isPending(AsyncNonMetaRegionLocator.LocateRequest req)
public void send(AsyncNonMetaRegionLocator.LocateRequest req)
public Optional<AsyncNonMetaRegionLocator.LocateRequest> getCandidate()
public void clearCompletedRequests(Optional<HRegionLocation> location)
private boolean tryComplete(AsyncNonMetaRegionLocator.LocateRequest req, CompletableFuture<HRegionLocation> future, Optional<HRegionLocation> location)
Copyright © 2007–2018 The Apache Software Foundation. All rights reserved.