org.apache.hadoop.hbase.client

Class AsyncTableRegionLocatorImpl

java.lang.Object

org.apache.hadoop.hbase.client.AsyncTableRegionLocatorImpl

All Implemented Interfaces:

AsyncTableRegionLocator

@InterfaceAudience.Private
class AsyncTableRegionLocatorImpl
extends Object
implements AsyncTableRegionLocator

The implementation of AsyncRegionLocator.

Field Summary

Fields

Modifier and Type	Field and Description
private AsyncConnectionImpl	conn
private TableName	tableName

Constructor Summary

Constructors

Constructor and Description
AsyncTableRegionLocatorImpl(TableName tableName, AsyncConnectionImpl conn)

Method Summary

Modifier and Type	Method and Description
void	clearRegionLocationCache() Clear all the entries in the region location cache.
CompletableFuture<List<HRegionLocation>>	getAllRegionLocations() Retrieves all of the regions associated with this table.
TableName	getName() Gets the fully qualified table name instance of the table whose region we want to locate.
CompletableFuture<HRegionLocation>	getRegionLocation(byte[] row, int replicaId, boolean reload) Finds the region with the given replicaId on which the given row is being served.
CompletableFuture<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.AsyncTableRegionLocator

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

Field Detail

tableName

private final TableName tableName

conn

private final AsyncConnectionImpl conn

Constructor Detail

AsyncTableRegionLocatorImpl

public AsyncTableRegionLocatorImpl(TableName tableName,
                                   AsyncConnectionImpl conn)

Method Detail

getName

public TableName getName()

Description copied from interface: AsyncTableRegionLocator

Gets the fully qualified table name instance of the table whose region we want to locate.

Specified by:

getName in interface AsyncTableRegionLocator

getRegionLocation

public CompletableFuture<HRegionLocation> getRegionLocation(byte[] row,
                                                            int replicaId,
                                                            boolean reload)

Description copied from interface: AsyncTableRegionLocator

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

Returns the location of the region with the given replicaId to which the row belongs.

Specified by:

getRegionLocation in interface AsyncTableRegionLocator

Parameters:

row - Row to find.

replicaId - the replica id of the region

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

getAllRegionLocations

public CompletableFuture<List<HRegionLocation>> getAllRegionLocations()

Description copied from interface: AsyncTableRegionLocator

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 AsyncTableRegionLocator

Returns:

a List of all regions associated with this table.

getRegionLocations

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

Description copied from interface: AsyncTableRegionLocator

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

Specified by:

getRegionLocations in interface AsyncTableRegionLocator

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.

clearRegionLocationCache

public void clearRegionLocationCache()

Description copied from interface: AsyncTableRegionLocator

Clear all the entries in the region location cache.

This may cause performance issue so use it with caution.

Specified by:

clearRegionLocationCache in interface AsyncTableRegionLocator