Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.client.backoff | |
org.apache.hadoop.hbase.exceptions | |
org.apache.hadoop.hbase.testing |
Modifier and Type | Field and Description |
---|---|
static List<ServerName> |
ServerName.EMPTY_SERVER_LIST |
Modifier and Type | Method and Description |
---|---|
ServerName |
ClusterMetrics.getMasterName()
Returns detailed information about the current master
ServerName . |
ServerName |
HBaseCluster.getServerHoldingMeta()
Deprecated.
Get the ServerName of region server serving the first hbase:meta region
|
abstract ServerName |
HBaseCluster.getServerHoldingRegion(TableName tn,
byte[] regionName)
Deprecated.
Get the ServerName of region server serving the specified region
|
ServerName |
MiniHBaseCluster.getServerHoldingRegion(TableName tn,
byte[] regionName)
Deprecated.
|
ServerName |
ServerMetrics.getServerName() |
ServerName |
HRegionLocation.getServerName() |
static ServerName |
ServerName.parseServerName(String str)
Parse a ServerName from a string
|
static ServerName |
ServerName.parseVersionedServerName(byte[] versionedBytes)
Use this method instantiating a
ServerName from bytes gotten from a call to
getVersionedBytes() . |
static ServerName |
ServerName.valueOf(Address address,
long startCode)
Retrieve an instance of
ServerName . |
static ServerName |
ServerName.valueOf(String serverName)
Retrieve an instance of ServerName.
|
static ServerName |
ServerName.valueOf(String hostname,
int port,
long startCode)
Retrieve an instance of ServerName.
|
static ServerName |
ServerName.valueOf(String hostAndPort,
long startCode)
Retrieve an instance of ServerName.
|
Modifier and Type | Method and Description |
---|---|
List<ServerName> |
ClusterMetrics.getBackupMasterNames()
Returns the names of backup masters
|
List<ServerName> |
ClusterMetrics.getDeadServerNames()
Returns the names of region servers on the dead list
|
List<ServerName> |
ClusterMetrics.getDecommissionedServerNames()
Returns the names of region servers on the decommissioned list
|
Map<ServerName,ServerMetrics> |
ClusterMetrics.getLiveServerMetrics()
Returns the names of region servers on the live list
|
List<ServerName> |
ClusterMetrics.getServersName() |
List<ServerName> |
ClusterMetrics.getUnknownServerNames()
Returns the names of region servers on the unknown list
|
Modifier and Type | Method and Description |
---|---|
void |
HBaseTestingUtility.assertRegionOnlyOnServer(RegionInfo hri,
ServerName server,
long timeout)
Deprecated.
Check to make sure the region is open on the specified region server, but not on any other one.
|
void |
HBaseTestingUtility.assertRegionOnServer(RegionInfo hri,
ServerName server,
long timeout)
Deprecated.
Due to async racing issue, a region may not be in the online region list of a region server
yet, after the assignment znode is deleted and the new assignment is recorded in master.
|
int |
ServerName.compareTo(ServerName other) |
org.apache.hadoop.hbase.regionserver.RegionServerServices |
HBaseTestingUtility.createMockRegionServerService(ServerName name)
Deprecated.
Create a stubbed out RegionServerService, mainly for getting FS.
|
protected int |
MiniHBaseCluster.getMasterIndex(ServerName serverName)
Deprecated.
|
org.apache.hadoop.hbase.regionserver.HRegionServer |
MiniHBaseCluster.getRegionServer(ServerName serverName)
Deprecated.
|
protected int |
MiniHBaseCluster.getRegionServerIndex(ServerName serverName)
Deprecated.
|
abstract boolean |
HBaseCluster.isKilledRS(ServerName serverName)
Deprecated.
Keeping track of killed servers and being able to check if a particular server was killed makes
it possible to do fault tolerance testing for dead servers in a deterministic way.
|
boolean |
MiniHBaseCluster.isKilledRS(ServerName serverName)
Deprecated.
|
static boolean |
ServerName.isSameAddress(ServerName left,
ServerName right)
Compare two addresses
|
abstract void |
HBaseCluster.killDataNode(ServerName serverName)
Deprecated.
Kills the datanode process if this is a distributed cluster, otherwise, this causes master to
exit doing basic clean up only.
|
void |
MiniHBaseCluster.killDataNode(ServerName serverName)
Deprecated.
|
abstract void |
HBaseCluster.killMaster(ServerName serverName)
Deprecated.
Kills the master process if this is a distributed cluster, otherwise, this causes master to
exit doing basic clean up only.
|
void |
MiniHBaseCluster.killMaster(ServerName serverName)
Deprecated.
|
abstract void |
HBaseCluster.killNameNode(ServerName serverName)
Deprecated.
Kills the namenode process if this is a distributed cluster, otherwise, this causes master to
exit doing basic clean up only.
|
void |
MiniHBaseCluster.killNameNode(ServerName serverName)
Deprecated.
|
abstract void |
HBaseCluster.killRegionServer(ServerName serverName)
Deprecated.
Kills the region server process if this is a distributed cluster, otherwise this causes the
region server to exit doing basic clean up only.
|
void |
MiniHBaseCluster.killRegionServer(ServerName serverName)
Deprecated.
|
abstract void |
HBaseCluster.killZkNode(ServerName serverName)
Deprecated.
Kills the zookeeper node process if this is a distributed cluster, otherwise, this causes
master to exit doing basic clean up only.
|
void |
MiniHBaseCluster.killZkNode(ServerName serverName)
Deprecated.
|
void |
HBaseTestingUtility.moveRegionAndWait(RegionInfo destRegion,
ServerName destServer)
Deprecated.
Move region to destination server and wait till region is completely moved and online
|
abstract void |
HBaseCluster.resumeRegionServer(ServerName serverName)
Deprecated.
Resume the region server
|
void |
MiniHBaseCluster.resumeRegionServer(ServerName serverName)
Deprecated.
|
abstract void |
HBaseCluster.startDataNode(ServerName serverName)
Deprecated.
Starts a new datanode on the given hostname or if this is a mini/local cluster, silently logs
warning message.
|
void |
MiniHBaseCluster.startDataNode(ServerName serverName)
Deprecated.
|
abstract void |
HBaseCluster.startNameNode(ServerName serverName)
Deprecated.
Starts a new namenode on the given hostname or if this is a mini/local cluster, silently logs
warning message.
|
void |
MiniHBaseCluster.startNameNode(ServerName serverName)
Deprecated.
|
abstract void |
HBaseCluster.stopDataNode(ServerName serverName)
Deprecated.
Stops the datanode if this is a distributed cluster, otherwise silently logs warning message.
|
void |
MiniHBaseCluster.stopDataNode(ServerName serverName)
Deprecated.
|
abstract void |
HBaseCluster.stopMaster(ServerName serverName)
Deprecated.
Stops the given master, by attempting a gradual stop.
|
void |
MiniHBaseCluster.stopMaster(ServerName serverName)
Deprecated.
|
abstract void |
HBaseCluster.stopNameNode(ServerName serverName)
Deprecated.
Stops the namenode if this is a distributed cluster, otherwise silently logs warning message.
|
void |
MiniHBaseCluster.stopNameNode(ServerName serverName)
Deprecated.
|
abstract void |
HBaseCluster.stopRegionServer(ServerName serverName)
Deprecated.
Stops the given region server, by attempting a gradual stop.
|
void |
MiniHBaseCluster.stopRegionServer(ServerName serverName)
Deprecated.
|
abstract void |
HBaseCluster.stopZkNode(ServerName serverName)
Deprecated.
Stops the region zookeeper if this is a distributed cluster, otherwise silently logs warning
message.
|
void |
MiniHBaseCluster.stopZkNode(ServerName serverName)
Deprecated.
|
abstract void |
HBaseCluster.suspendRegionServer(ServerName serverName)
Deprecated.
Suspend the region server
|
void |
MiniHBaseCluster.suspendRegionServer(ServerName serverName)
Deprecated.
|
abstract void |
HBaseCluster.waitForDataNodeToStart(ServerName serverName,
long timeout)
Deprecated.
Wait for the specified datanode to join the cluster
|
void |
MiniHBaseCluster.waitForDataNodeToStart(ServerName serverName,
long timeout)
Deprecated.
|
abstract void |
HBaseCluster.waitForDataNodeToStop(ServerName serverName,
long timeout)
Deprecated.
Wait for the specified datanode to stop the thread / process.
|
void |
MiniHBaseCluster.waitForDataNodeToStop(ServerName serverName,
long timeout)
Deprecated.
|
abstract void |
HBaseCluster.waitForMasterToStop(ServerName serverName,
long timeout)
Deprecated.
Wait for the specified master to stop the thread / process.
|
void |
MiniHBaseCluster.waitForMasterToStop(ServerName serverName,
long timeout)
Deprecated.
|
abstract void |
HBaseCluster.waitForNameNodeToStart(ServerName serverName,
long timeout)
Deprecated.
Wait for the specified namenode to join the cluster
|
void |
MiniHBaseCluster.waitForNameNodeToStart(ServerName serverName,
long timeout)
Deprecated.
|
abstract void |
HBaseCluster.waitForNameNodeToStop(ServerName serverName,
long timeout)
Deprecated.
Wait for the specified namenode to stop
|
void |
MiniHBaseCluster.waitForNameNodeToStop(ServerName serverName,
long timeout)
Deprecated.
|
abstract void |
HBaseCluster.waitForRegionServerToStop(ServerName serverName,
long timeout)
Deprecated.
Wait for the specified region server to stop the thread / process.
|
void |
MiniHBaseCluster.waitForRegionServerToStop(ServerName serverName,
long timeout)
Deprecated.
|
abstract void |
HBaseCluster.waitForZkNodeToStart(ServerName serverName,
long timeout)
Deprecated.
Wait for the specified zookeeper node to join the cluster
|
void |
MiniHBaseCluster.waitForZkNodeToStart(ServerName serverName,
long timeout)
Deprecated.
|
abstract void |
HBaseCluster.waitForZkNodeToStop(ServerName serverName,
long timeout)
Deprecated.
Wait for the specified zookeeper node to stop the thread / process.
|
void |
MiniHBaseCluster.waitForZkNodeToStop(ServerName serverName,
long timeout)
Deprecated.
|
Constructor and Description |
---|
HRegionLocation(RegionInfo regionInfo,
ServerName serverName) |
HRegionLocation(RegionInfo regionInfo,
ServerName serverName,
long seqNum) |
Modifier and Type | Method and Description |
---|---|
default ServerName |
Admin.getMaster()
Get the current active master.
|
Modifier and Type | Method and Description |
---|---|
List<ServerName> |
Admin.clearDeadServers(List<ServerName> servers)
Clear dead region servers from master.
|
CompletableFuture<List<ServerName>> |
AsyncAdmin.clearDeadServers(List<ServerName> servers)
Clear dead region servers from master.
|
Map<ServerName,Boolean> |
Admin.compactionSwitch(boolean switchState,
List<String> serverNamesList)
Turn the compaction on or off.
|
CompletableFuture<Map<ServerName,Boolean>> |
AsyncAdmin.compactionSwitch(boolean switchState,
List<String> serverNamesList)
Turn the compaction on or off.
|
static <S,R> CompletableFuture<Map<ServerName,Object>> |
AsyncAdminClientUtils.coprocessorServiceOnAllRegionServers(AsyncAdmin asyncAdmin,
Function<org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel,S> stubMaker,
ServiceCaller<S,R> callable)
Execute the given coprocessor call on all region servers.
|
default Collection<ServerName> |
Admin.getBackupMasters()
Get a list of current backup masters.
|
default CompletableFuture<Collection<ServerName>> |
AsyncAdmin.getBackupMasters()
Returns current backup master list wrapped by
CompletableFuture |
default CompletableFuture<ServerName> |
AsyncAdmin.getMaster()
Returns current master server name wrapped by
CompletableFuture |
default Collection<ServerName> |
Admin.getRegionServers()
Get the live server list.
|
default CompletableFuture<Collection<ServerName>> |
AsyncAdmin.getRegionServers()
Returns current live region servers list wrapped by
CompletableFuture |
default Collection<ServerName> |
Admin.getRegionServers(boolean excludeDecommissionedRS)
Retrieve all current live region servers including decommissioned if excludeDecommissionedRS is
false, else non-decommissioned ones only
|
default CompletableFuture<Collection<ServerName>> |
AsyncAdmin.getRegionServers(boolean excludeDecommissionedRS) |
default List<ServerName> |
Admin.listDeadServers()
List dead region servers.
|
default CompletableFuture<List<ServerName>> |
AsyncAdmin.listDeadServers()
List all the dead region servers.
|
List<ServerName> |
Admin.listDecommissionedRegionServers()
List region servers marked as decommissioned, which can not be assigned regions.
|
CompletableFuture<List<ServerName>> |
AsyncAdmin.listDecommissionedRegionServers()
List region servers marked as decommissioned, which can not be assigned regions.
|
default List<ServerName> |
Admin.listUnknownServers()
List unknown region servers.
|
default CompletableFuture<List<ServerName>> |
AsyncAdmin.listUnknownServers()
List all the unknown region servers.
|
Modifier and Type | Method and Description |
---|---|
void |
Admin.clearCompactionQueues(ServerName serverName,
Set<String> queues)
Clear compacting queues on a regionserver.
|
CompletableFuture<Void> |
AsyncAdmin.clearCompactionQueues(ServerName serverName,
Set<String> queues)
Clear compacting queues on a region server.
|
void |
Admin.compactRegionServer(ServerName serverName)
Compact all regions on the region server.
|
CompletableFuture<Void> |
AsyncAdmin.compactRegionServer(ServerName serverName)
Compact all regions on the region server.
|
<S,R> CompletableFuture<R> |
AsyncAdmin.coprocessorService(Function<org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel,S> stubMaker,
ServiceCaller<S,R> callable,
ServerName serverName)
Execute the given coprocessor call on the given region server.
|
CoprocessorRpcChannel |
Admin.coprocessorService(ServerName serverName)
Deprecated.
since 3.0.0, will removed in 4.0.0. This is too low level, please stop using it any
more. Use the coprocessorService methods in
AsyncAdmin instead. |
void |
RequestController.decTaskCounters(Collection<byte[]> regions,
ServerName sn)
Decrement the counter if a task is accomplished.
|
void |
Admin.flushRegionServer(ServerName serverName)
Flush all regions on the region server.
|
CompletableFuture<Void> |
AsyncAdmin.flushRegionServer(ServerName serverName)
Flush all region on the region server.
|
List<String> |
Admin.getCachedFilesList(ServerName serverName)
Get the list of cached files
|
CompletableFuture<List<String>> |
AsyncAdmin.getCachedFilesList(ServerName serverName)
Get the list of cached files
|
org.apache.hadoop.hbase.client.Hbck |
AsyncConnection.getHbck(ServerName masterServer)
Retrieve an Hbck implementation to fix an HBase cluster.
|
default org.apache.hadoop.hbase.client.Hbck |
Connection.getHbck(ServerName masterServer)
Retrieve an Hbck implementation to fix an HBase cluster.
|
List<RegionMetrics> |
Admin.getRegionMetrics(ServerName serverName)
Get
RegionMetrics of all regions hosted on a regionserver. |
CompletableFuture<List<RegionMetrics>> |
AsyncAdmin.getRegionMetrics(ServerName serverName)
Get a list of
RegionMetrics of all regions hosted on a region server. |
List<RegionMetrics> |
Admin.getRegionMetrics(ServerName serverName,
TableName tableName)
Get
RegionMetrics of all regions hosted on a regionserver for a table. |
CompletableFuture<List<RegionMetrics>> |
AsyncAdmin.getRegionMetrics(ServerName serverName,
TableName tableName)
Get a list of
RegionMetrics of all regions hosted on a region server for a table. |
List<RegionInfo> |
Admin.getRegions(ServerName serverName)
Get all the online regions on a region server.
|
CompletableFuture<List<RegionInfo>> |
AsyncAdmin.getRegions(ServerName serverName)
Get all the online regions on a region server.
|
Map<TableName,? extends SpaceQuotaSnapshotView> |
Admin.getRegionServerSpaceQuotaSnapshots(ServerName serverName)
Fetches the observed
SpaceQuotaSnapshotView s observed by a RegionServer. |
CompletableFuture<? extends Map<TableName,? extends SpaceQuotaSnapshotView>> |
AsyncAdmin.getRegionServerSpaceQuotaSnapshots(ServerName serverName)
Fetches the observed
SpaceQuotaSnapshotView s observed by a RegionServer. |
void |
RequestController.incTaskCounters(Collection<byte[]> regions,
ServerName sn)
Increment the counter if we build a valid task.
|
void |
Admin.majorCompactRegionServer(ServerName serverName)
Major compact all regions on the region server.
|
CompletableFuture<Void> |
AsyncAdmin.majorCompactRegionServer(ServerName serverName)
Compact all regions on the region server.
|
void |
Admin.move(byte[] encodedRegionName,
ServerName destServerName)
Move the region
encodedRegionName to destServerName . |
CompletableFuture<Void> |
AsyncAdmin.move(byte[] regionName,
ServerName destServerName)
Move the region
r to dest . |
void |
Admin.recommissionRegionServer(ServerName server,
List<byte[]> encodedRegionNames)
Remove decommission marker from a region server to allow regions assignments.
|
CompletableFuture<Void> |
AsyncAdmin.recommissionRegionServer(ServerName server,
List<byte[]> encodedRegionNames)
Remove decommission marker from a region server to allow regions assignments.
|
void |
Admin.rollWALWriter(ServerName serverName)
Roll the log writer.
|
CompletableFuture<Void> |
AsyncAdmin.rollWALWriter(ServerName serverName)
Roll the log writer.
|
CompletableFuture<Void> |
AsyncAdmin.stopRegionServer(ServerName serverName)
Stop the designated regionserver.
|
void |
Admin.updateConfiguration(ServerName server)
Update the configuration and trigger an online config change on the regionserver.
|
CompletableFuture<Void> |
AsyncAdmin.updateConfiguration(ServerName serverName)
Update the configuration and trigger an online config change on the regionserver.
|
Modifier and Type | Method and Description |
---|---|
List<ServerName> |
Admin.clearDeadServers(List<ServerName> servers)
Clear dead region servers from master.
|
CompletableFuture<List<ServerName>> |
AsyncAdmin.clearDeadServers(List<ServerName> servers)
Clear dead region servers from master.
|
List<Boolean> |
Admin.clearSlowLogResponses(Set<ServerName> serverNames)
Clears online slow/large RPC logs from the provided list of RegionServers
|
CompletableFuture<List<Boolean>> |
AsyncAdmin.clearSlowLogResponses(Set<ServerName> serverNames)
Clears online slow RPC logs from the provided list of RegionServers
|
void |
Admin.decommissionRegionServers(List<ServerName> servers,
boolean offload)
Mark region server(s) as decommissioned to prevent additional regions from getting assigned to
them.
|
CompletableFuture<Void> |
AsyncAdmin.decommissionRegionServers(List<ServerName> servers,
boolean offload)
Mark region server(s) as decommissioned to prevent additional regions from getting assigned to
them.
|
List<LogEntry> |
Admin.getLogEntries(Set<ServerName> serverNames,
String logType,
ServerType serverType,
int limit,
Map<String,Object> filterParams)
Retrieve recent online records from HMaster / RegionServers.
|
CompletableFuture<List<LogEntry>> |
AsyncAdmin.getLogEntries(Set<ServerName> serverNames,
String logType,
ServerType serverType,
int limit,
Map<String,Object> filterParams)
Retrieve recent online records from HMaster / RegionServers.
|
default List<OnlineLogRecord> |
Admin.getSlowLogResponses(Set<ServerName> serverNames,
LogQueryFilter logQueryFilter)
Deprecated.
since 2.4.0 and will be removed in 4.0.0. Use
Admin.getLogEntries(Set, String, ServerType, int, Map) instead. |
default CompletableFuture<List<OnlineLogRecord>> |
AsyncAdmin.getSlowLogResponses(Set<ServerName> serverNames,
LogQueryFilter logQueryFilter)
Deprecated.
since 2.4.0 and will be removed in 4.0.0. Use
AsyncAdmin.getLogEntries(Set, String, ServerType, int, Map) instead. |
Modifier and Type | Method and Description |
---|---|
long |
ExponentialClientBackoffPolicy.getBackoffTime(ServerName serverName,
byte[] region,
org.apache.hadoop.hbase.client.backoff.ServerStatistics stats) |
long |
ClientBackoffPolicy.getBackoffTime(ServerName serverName,
byte[] region,
org.apache.hadoop.hbase.client.backoff.ServerStatistics stats)
Returns the number of ms to wait on the client based on the
|
Constructor and Description |
---|
PreemptiveFastFailException(long count,
long timeOfFirstFailureMilliSec,
long timeOfLatestAttemptMilliSec,
ServerName serverName)
Deprecated.
|
PreemptiveFastFailException(long count,
long timeOfFirstFailureMilliSec,
long timeOfLatestAttemptMilliSec,
ServerName serverName,
boolean guaranteedClientSideOnly)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Optional<ServerName> |
TestingHBaseCluster.getActiveMasterAddress()
Get the address of active master if there is one.
|
List<ServerName> |
TestingHBaseCluster.getBackupMasterAddresses()
Get all the backup master addresses.
|
List<ServerName> |
TestingHBaseCluster.getRegionServerAddresses()
Get all the region server addresses.
|
Modifier and Type | Method and Description |
---|---|
Optional<org.apache.hadoop.hbase.regionserver.OnlineRegions> |
TestingHBaseCluster.getOnlineRegionsInterface(ServerName serverName)
Get the server side
OnlineRegions interface for the specific region server. |
CompletableFuture<Void> |
TestingHBaseCluster.stopMaster(ServerName serverName)
Stop the given master.
|
CompletableFuture<Void> |
TestingHBaseCluster.stopRegionServer(ServerName serverName)
Stop the given region server.
|
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.