| Package | Description |
|---|---|
| org.apache.hadoop.hbase | |
| org.apache.hadoop.hbase.client |
Provides HBase Client
|
| org.apache.hadoop.hbase.master.assignment | |
| org.apache.hadoop.hbase.shaded.protobuf | |
| org.apache.hadoop.hbase.thrift2 |
Provides an HBase Thrift
service.
|
| Modifier and Type | Method and Description |
|---|---|
HRegionLocation |
RegionLocations.getDefaultRegionLocation() |
HRegionLocation |
RegionLocations.getRegionLocation()
Returns the first not-null region location in the list
|
static HRegionLocation |
MetaTableAccessor.getRegionLocation(Connection connection,
byte[] regionName)
Returns the HRegionLocation from meta for the given region
|
static HRegionLocation |
MetaTableAccessor.getRegionLocation(Connection connection,
RegionInfo regionInfo)
Returns the HRegionLocation from meta for the given region
|
HRegionLocation |
RegionLocations.getRegionLocation(int replicaId) |
HRegionLocation |
RegionLocations.getRegionLocationByRegionName(byte[] regionName)
Returns the region location from the list for matching regionName, which can
be regionName or encodedRegionName
|
HRegionLocation[] |
RegionLocations.getRegionLocations() |
| Modifier and Type | Method and Description |
|---|---|
static CompletableFuture<Optional<HRegionLocation>> |
AsyncMetaTableAccessor.getRegionLocation(AsyncTable<?> metaTable,
byte[] regionName)
Returns the HRegionLocation from meta for the given region
|
static CompletableFuture<Optional<HRegionLocation>> |
AsyncMetaTableAccessor.getRegionLocationWithEncodedName(AsyncTable<?> metaTable,
byte[] encodedRegionName)
Returns the HRegionLocation from meta for the given encoded region name
|
static CompletableFuture<List<HRegionLocation>> |
AsyncMetaTableAccessor.getTableHRegionLocations(AsyncTable<AdvancedScanResultConsumer> metaTable,
Optional<TableName> tableName)
Used to get all region locations for the specific table.
|
| Modifier and Type | Method and Description |
|---|---|
int |
HRegionLocation.compareTo(HRegionLocation o) |
RegionLocations |
RegionLocations.remove(HRegionLocation location)
Removes the given location from the list
|
RegionLocations |
RegionLocations.updateLocation(HRegionLocation location,
boolean checkForEquals,
boolean force)
Updates the location with new only if the new location has a higher
seqNum than the old one or force is true.
|
| Constructor and Description |
|---|
RegionLocations(HRegionLocation... locations)
Constructs the region location list.
|
| Constructor and Description |
|---|
RegionLocations(Collection<HRegionLocation> locations) |
| Modifier and Type | Field and Description |
|---|---|
protected HRegionLocation |
RegionAdminServiceCallable.location |
protected HRegionLocation |
RegionServerCallable.location
Some subclasses want to set their own location.
|
| Modifier and Type | Method and Description |
|---|---|
protected HRegionLocation |
RegionServerCallable.getLocation() |
HRegionLocation |
RegionAdminServiceCallable.getLocation(boolean useCache) |
HRegionLocation |
HRegionLocator.getRegionLocation(byte[] row)
Finds the region on which the given row is being served.
|
HRegionLocation |
RegionLocator.getRegionLocation(byte[] row)
Finds the region on which the given row is being served.
|
HRegionLocation |
HRegionLocator.getRegionLocation(byte[] row,
boolean reload)
Finds the region on which the given row is being served.
|
HRegionLocation |
RegionLocator.getRegionLocation(byte[] row,
boolean reload)
Finds the region on which the given row is being served.
|
HRegionLocation |
ClusterConnection.getRegionLocation(TableName tableName,
byte[] row,
boolean reload)
Find region location hosting passed row
|
HRegionLocation |
ClusterConnection.locateRegion(byte[] regionName)
Gets the location of the region of regionName.
|
HRegionLocation |
ClusterConnection.locateRegion(TableName tableName,
byte[] row)
Find the location of the region of tableName that row
lives in.
|
HRegionLocation |
ClusterConnection.relocateRegion(TableName tableName,
byte[] row)
Find the location of the region of tableName that row
lives in, ignoring any value that might be in the cache.
|
| Modifier and Type | Method and Description |
|---|---|
List<HRegionLocation> |
HRegionLocator.getAllRegionLocations() |
List<HRegionLocation> |
RegionLocator.getAllRegionLocations()
Retrieves all of the regions associated with this table.
|
default CompletableFuture<HRegionLocation> |
AsyncTableRegionLocator.getRegionLocation(byte[] row)
Finds the region on which the given row is being served.
|
default CompletableFuture<HRegionLocation> |
AsyncTableRegionLocator.getRegionLocation(byte[] row,
boolean reload)
Finds the region on which the given row is being served.
|
default CompletableFuture<HRegionLocation> |
AsyncTableRegionLocator.getRegionLocation(byte[] row,
int replicaId)
Finds the region with the given
replicaId on which the given row is being served. |
CompletableFuture<HRegionLocation> |
AsyncTableRegionLocator.getRegionLocation(byte[] row,
int replicaId,
boolean reload)
Finds the region with the given
replicaId on which the given row is being served. |
List<HRegionLocation> |
ClusterConnection.locateRegions(TableName tableName)
Gets the locations of all regions in the specified table, tableName.
|
List<HRegionLocation> |
ClusterConnection.locateRegions(TableName tableName,
boolean useCache,
boolean offlined)
Gets the locations of all regions in the specified table, tableName.
|
| Modifier and Type | Method and Description |
|---|---|
void |
MetaCache.cacheLocation(TableName tableName,
ServerName source,
HRegionLocation location)
Put a newly discovered HRegionLocation into the cache.
|
RequestController.ReturnCode |
RequestController.Checker.canTakeRow(HRegionLocation loc,
Row row)
Checks the data whether it is valid to submit.
|
void |
MetaCache.clearCache(HRegionLocation location) |
void |
ClusterConnection.deleteCachedRegionLocation(HRegionLocation location)
Deletes cached locations for the specific region.
|
protected void |
RegionServerCallable.setLocation(HRegionLocation location) |
static <T> T |
ResultStatsUtil.updateStats(T r,
ServerStatisticTracker stats,
HRegionLocation regionLocation) |
| Constructor and Description |
|---|
RegionAdminServiceCallable(ClusterConnection connection,
RpcControllerFactory rpcControllerFactory,
HRegionLocation location,
TableName tableName,
byte[] row) |
RegionAdminServiceCallable(ClusterConnection connection,
RpcControllerFactory rpcControllerFactory,
HRegionLocation location,
TableName tableName,
byte[] row,
int replicaId) |
| Constructor and Description |
|---|
HTableMultiplexerStatus(Map<HRegionLocation,org.apache.hadoop.hbase.client.HTableMultiplexer.FlushWorker> serverToFlushWorkerMap) |
| Modifier and Type | Method and Description |
|---|---|
HRegionLocation |
RegionStates.checkReopened(HRegionLocation oldLoc)
Check whether the region has been reopened.
|
| Modifier and Type | Method and Description |
|---|---|
List<HRegionLocation> |
RegionStates.getRegionsOfTableForReopen(TableName tableName)
Get the regions to be reopened when modifying a table.
|
| Modifier and Type | Method and Description |
|---|---|
HRegionLocation |
RegionStates.checkReopened(HRegionLocation oldLoc)
Check whether the region has been reopened.
|
| Modifier and Type | Method and Description |
|---|---|
static HRegionLocation |
ProtobufUtil.toRegionLocation(HBaseProtos.RegionLocation proto) |
| Modifier and Type | Method and Description |
|---|---|
static HBaseProtos.RegionLocation |
ProtobufUtil.toRegionLocation(HRegionLocation loc) |
| Modifier and Type | Method and Description |
|---|---|
static THRegionLocation |
ThriftUtilities.regionLocationFromHBase(HRegionLocation hrl) |
| Modifier and Type | Method and Description |
|---|---|
static List<THRegionLocation> |
ThriftUtilities.regionLocationsFromHBase(List<HRegionLocation> locations) |
Copyright © 2007–2019 Cloudera. All rights reserved.