org.apache.hadoop.hbase.client

Class AsyncRegionLocatorHelper

java.lang.Object

org.apache.hadoop.hbase.client.AsyncRegionLocatorHelper

@InterfaceAudience.Private
final class AsyncRegionLocatorHelper
extends Object

Helper class for asynchronous region locator.

Field Summary

Fields

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

Constructor Summary

Constructors

Modifier	Constructor and Description
private	AsyncRegionLocatorHelper()

Method Summary

Modifier and Type	Method and 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 Detail

LOG

private static final org.slf4j.Logger LOG

Constructor Detail

AsyncRegionLocatorHelper

private AsyncRegionLocatorHelper()

Method Detail

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)