Package org.apache.hadoop.hbase.client

Class RegionLocatorOverAsyncTableRegionLocator

java.lang.Object

org.apache.hadoop.hbase.client.RegionLocatorOverAsyncTableRegionLocator

All Implemented Interfaces:

Closeable, AutoCloseable, RegionLocator

@Private
class RegionLocatorOverAsyncTableRegionLocator
extends Object
implements RegionLocator

The RegionLocator implementation based on AsyncTableRegionLocator.

Field Summary

Fields

Modifier and Type	Field	Description
private final AsyncTableRegionLocator	locator

Fields inherited from interface org.apache.hadoop.hbase.client.RegionLocator

LOCATOR_META_REPLICAS_MODE, LOCATOR_META_REPLICAS_MODE_LOADBALANCE_SELECTOR

Constructor Summary

Constructors

Constructor	Description
RegionLocatorOverAsyncTableRegionLocator(AsyncTableRegionLocator locator)

Method Summary

Modifier and Type	Method	Description
void	clearRegionLocationCache()	Clear all the entries in the region location cache.
void	close()
List<HRegionLocation>	getAllRegionLocations()	Retrieves all of the regions associated with this table.
TableName	getName()	Gets the fully qualified table name instance of this table.
HRegionLocation	getRegionLocation(byte[] row, int replicaId, boolean reload)	Finds the region with the given replica id on which the given row is being served.
List<HRegionLocation>	getRegionLocations(byte[] row, boolean reload)	Find all the replicas for the region on which the given row is being served.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.client.RegionLocator

getEndKeys, getRegionLocation, getRegionLocation, getRegionLocation, getRegionLocations, getStartEndKeys, getStartKeys

Field Details

locator

private final AsyncTableRegionLocator locator

Constructor Details

RegionLocatorOverAsyncTableRegionLocator

RegionLocatorOverAsyncTableRegionLocator(AsyncTableRegionLocator locator)

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

getRegionLocation

public HRegionLocation getRegionLocation(byte[] row,
 int replicaId,
 boolean reload)
                                  throws IOException

Description copied from interface: RegionLocator

Finds the region with the given replica id on which the given row is being served.

Specified by:

getRegionLocation in interface RegionLocator

Parameters:

row - Row to find.

replicaId - the replica id

reload - true to reload information or false to use cached information

Returns:

Location of the row.

Throws:

IOException - if a remote or network exception occurs

getRegionLocations

public List<HRegionLocation> getRegionLocations(byte[] row,
 boolean reload)
                                         throws IOException

Description copied from interface: RegionLocator

Find all the replicas for the region on which the given row is being served.

Specified by:

getRegionLocations in interface RegionLocator

Parameters:

row - Row to find.

reload - true to reload information or false to use cached information

Returns:

Locations for all the replicas of the row.

Throws:

IOException - if a remote or network exception occurs

clearRegionLocationCache

public void clearRegionLocationCache()

Description copied from interface: RegionLocator

Clear all the entries in the region location cache.

This may cause performance issue so use it with caution.

Specified by:

clearRegionLocationCache in interface RegionLocator

getAllRegionLocations

public List<HRegionLocation> getAllRegionLocations()
                                            throws IOException

Description copied from interface: RegionLocator

Retrieves all of the regions associated with this table.

Usually we will go to meta table directly in this method so there is no reload parameter.

Notice that the location for region replicas other than the default replica are also returned.

Specified by:

getAllRegionLocations in interface RegionLocator

Returns:

a List of all regions associated with this table.

Throws:

IOException - if a remote or network exception occurs

getName

public TableName getName()

Description copied from interface: RegionLocator

Gets the fully qualified table name instance of this table.

Specified by:

getName in interface RegionLocator