Package org.apache.hadoop.hbase

Class ClientMetaTableAccessor

java.lang.Object

org.apache.hadoop.hbase.ClientMetaTableAccessor

@Private
public final class ClientMetaTableAccessor
extends Object

The (asynchronous) meta table accessor used at client side. Used to read/write region and assignment information store in hbase:meta.

Since:

2.0.0

See Also:

• CatalogFamilyFormat

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ClientMetaTableAccessor.CloseableVisitor	Implementations 'visit' a catalog table row but with close() at the end.
(package private) static class	ClientMetaTableAccessor.CollectAllVisitor	Collects all returned.
private static class	ClientMetaTableAccessor.CollectingVisitor<T>	A ClientMetaTableAccessor.Visitor that collects content out of passed Result.
(package private) static class	ClientMetaTableAccessor.CollectRegionLocationsVisitor
private static final class	ClientMetaTableAccessor.MetaTableScanResultConsumer
static enum	ClientMetaTableAccessor.QueryType
static interface	ClientMetaTableAccessor.Visitor	Implementations 'visit' a catalog table row.

Field Summary

Fields

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

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ClientMetaTableAccessor()

Method Summary

Modifier and Type	Method	Description
private static Scan	getMetaScan(AsyncTable<?> metaTable, int rowUpperLimit)
static CompletableFuture<Optional<HRegionLocation>>	getRegionLocation(AsyncTable<?> metaTable, byte[] regionName)	Returns the HRegionLocation from meta for the given region
private static Optional<RegionLocations>	getRegionLocations(Result r)	Returns an HRegionLocationList extracted from the result.
static CompletableFuture<Optional<HRegionLocation>>	getRegionLocationWithEncodedName(AsyncTable<?> metaTable, byte[] encodedRegionName)	Returns the HRegionLocation from meta for the given encoded region name
static CompletableFuture<List<HRegionLocation>>	getTableHRegionLocations(AsyncTable<AdvancedScanResultConsumer> metaTable, TableName tableName)	Used to get all region locations for the specific table
private static CompletableFuture<List<Pair<RegionInfo,ServerName>>>	getTableRegionsAndLocations(AsyncTable<AdvancedScanResultConsumer> metaTable, TableName tableName, boolean excludeOfflinedSplitParents)	Used to get table regions' info and server.
static byte[]	getTableStartRowForMeta(TableName tableName, ClientMetaTableAccessor.QueryType type)	Returns start row for scanning META according to query type
static CompletableFuture<Optional<TableState>>	getTableState(AsyncTable<?> metaTable, TableName tableName)
private static Optional<TableState>	getTableState(Result r)
static byte[]	getTableStopRowForMeta(TableName tableName, ClientMetaTableAccessor.QueryType type)	Returns stop row for scanning META according to query type
private static CompletableFuture<Void>	scanMeta(AsyncTable<AdvancedScanResultConsumer> metaTable, byte[] startRow, byte[] stopRow, ClientMetaTableAccessor.QueryType type, int maxRows, ClientMetaTableAccessor.Visitor visitor)	Performs a scan of META table for given table.
private static CompletableFuture<Void>	scanMeta(AsyncTable<AdvancedScanResultConsumer> metaTable, TableName tableName, ClientMetaTableAccessor.QueryType type, ClientMetaTableAccessor.Visitor visitor)	Performs a scan of META table for given table.
static CompletableFuture<Boolean>	tableExists(AsyncTable<?> metaTable, TableName tableName)

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

ClientMetaTableAccessor

private ClientMetaTableAccessor()

Method Details

tableExists

public static CompletableFuture<Boolean> tableExists(AsyncTable<?> metaTable,
 TableName tableName)

getTableState

public static CompletableFuture<Optional<TableState>> getTableState(AsyncTable<?> metaTable,
 TableName tableName)

getRegionLocation

public static CompletableFuture<Optional<HRegionLocation>> getRegionLocation(AsyncTable<?> metaTable,
 byte[] regionName)

Returns the HRegionLocation from meta for the given region

getRegionLocationWithEncodedName

public static CompletableFuture<Optional<HRegionLocation>> getRegionLocationWithEncodedName(AsyncTable<?> metaTable,
 byte[] encodedRegionName)

Returns the HRegionLocation from meta for the given encoded region name

getTableState

private static Optional<TableState> getTableState(Result r)
                                           throws IOException

Throws:

IOException

getTableHRegionLocations

public static CompletableFuture<List<HRegionLocation>> getTableHRegionLocations(AsyncTable<AdvancedScanResultConsumer> metaTable,
 TableName tableName)

Used to get all region locations for the specific table

Parameters:

metaTable - scanner over meta table

tableName - table we're looking for, can be null for getting all regions

Returns:

the list of region locations. The return value will be wrapped by a CompletableFuture.

getTableRegionsAndLocations

private static CompletableFuture<List<Pair<RegionInfo,ServerName>>> getTableRegionsAndLocations(AsyncTable<AdvancedScanResultConsumer> metaTable,
 TableName tableName,
 boolean excludeOfflinedSplitParents)

Used to get table regions' info and server.

Parameters:

metaTable - scanner over meta table

tableName - table we're looking for, can be null for getting all regions

excludeOfflinedSplitParents - don't return split parents

Returns:

the list of regioninfos and server. The return value will be wrapped by a CompletableFuture.

scanMeta

private static CompletableFuture<Void> scanMeta(AsyncTable<AdvancedScanResultConsumer> metaTable,
 TableName tableName,
 ClientMetaTableAccessor.QueryType type,
 ClientMetaTableAccessor.Visitor visitor)

Performs a scan of META table for given table.

Parameters:

metaTable - scanner over meta table

tableName - table within we scan

type - scanned part of meta

visitor - Visitor invoked against each row

scanMeta

private static CompletableFuture<Void> scanMeta(AsyncTable<AdvancedScanResultConsumer> metaTable,
 byte[] startRow,
 byte[] stopRow,
 ClientMetaTableAccessor.QueryType type,
 int maxRows,
 ClientMetaTableAccessor.Visitor visitor)

Performs a scan of META table for given table.

Parameters:

metaTable - scanner over meta table

startRow - Where to start the scan

stopRow - Where to stop the scan

type - scanned part of meta

maxRows - maximum rows to return

visitor - Visitor invoked against each row

getMetaScan

private static Scan getMetaScan(AsyncTable<?> metaTable,
 int rowUpperLimit)

getRegionLocations

private static Optional<RegionLocations> getRegionLocations(Result r)

Returns an HRegionLocationList extracted from the result.

getTableStartRowForMeta

public static byte[] getTableStartRowForMeta(TableName tableName,
 ClientMetaTableAccessor.QueryType type)

Returns start row for scanning META according to query type

getTableStopRowForMeta

public static byte[] getTableStopRowForMeta(TableName tableName,
 ClientMetaTableAccessor.QueryType type)

Returns stop row for scanning META according to query type