Package org.apache.hadoop.hbase.client

Class AsyncRegionLocatorHelper

java.lang.Object

org.apache.hadoop.hbase.client.AsyncRegionLocatorHelper

@Private
final class AsyncRegionLocatorHelper
extends Object

Helper class for asynchronous region locator.

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG

Constructor Summary

Constructors

Modifier	Constructor	Description
private	AsyncRegionLocatorHelper()

Method Summary

Modifier and Type	Method	Description
(package private) static boolean	canUpdateOnError(HRegionLocation loc, HRegionLocation oldLoc)
(package private) static RegionLocations	createRegionLocations(HRegionLocation loc)
(package private) static boolean	isGood(RegionLocations locs, int replicaId)
(package private) static RegionLocations	removeRegionLocation(RegionLocations oldLocs, int replicaId)	Create a new RegionLocations based on the given oldLocs, and remove the location for the given replicaId.
(package private) static RegionLocations	replaceRegionLocation(RegionLocations oldLocs, HRegionLocation loc)	Create a new RegionLocations based on the given oldLocs, and replace the location for the given replicaId with the given loc.
(package private) static void	updateCachedLocationOnError(HRegionLocation loc, Throwable exception, Function<HRegionLocation,HRegionLocation> cachedLocationSupplier, Consumer<HRegionLocation> addToCache, Consumer<HRegionLocation> removeFromCache, MetricsConnection metrics)

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

Constructor Details

AsyncRegionLocatorHelper

private AsyncRegionLocatorHelper()

Method Details

canUpdateOnError

static boolean canUpdateOnError(HRegionLocation loc,
 HRegionLocation oldLoc)

updateCachedLocationOnError

static void updateCachedLocationOnError(HRegionLocation loc,
 Throwable exception,
 Function<HRegionLocation,HRegionLocation> cachedLocationSupplier,
 Consumer<HRegionLocation> addToCache,
 Consumer<HRegionLocation> removeFromCache,
 MetricsConnection metrics)

createRegionLocations

static RegionLocations createRegionLocations(HRegionLocation loc)

replaceRegionLocation

static RegionLocations replaceRegionLocation(RegionLocations oldLocs,
 HRegionLocation loc)

Create a new RegionLocations based on the given oldLocs, and replace the location for the given replicaId with the given loc.

All the RegionLocations in async locator related class are immutable because we want to access them concurrently, so here we need to create a new one, instead of calling RegionLocations.updateLocation(HRegionLocation, boolean, boolean).

removeRegionLocation

static RegionLocations removeRegionLocation(RegionLocations oldLocs,
 int replicaId)

Create a new RegionLocations based on the given oldLocs, and remove the location for the given replicaId.

All the RegionLocations in async locator related class are immutable because we want to access them concurrently, so here we need to create a new one, instead of calling RegionLocations.remove(int).

isGood

static boolean isGood(RegionLocations locs,
 int replicaId)