public class DistributedHBaseCluster
extends HBaseCluster
Constructor and Description |
---|
DistributedHBaseCluster(Configuration conf,
org.apache.hadoop.hbase.ClusterManager clusterManager) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
AdminProtos.AdminService.BlockingInterface |
getAdminProtocol(ServerName serverName) |
ClientProtos.ClientService.BlockingInterface |
getClientProtocol(ServerName serverName) |
org.apache.hadoop.hbase.ClusterManager |
getClusterManager() |
ClusterMetrics |
getClusterMetrics()
Returns a ClusterStatus for this HBase cluster
|
ClusterMetrics |
getInitialClusterMetrics() |
MasterService.BlockingInterface |
getMasterAdminService() |
ServerName |
getServerHoldingRegion(TableName tn,
byte[] regionName) |
boolean |
isDistributedCluster() |
boolean |
isKilledRS(ServerName serverName) |
void |
killDataNode(ServerName serverName) |
void |
killMaster(ServerName serverName) |
void |
killRegionServer(ServerName serverName) |
void |
killZkNode(ServerName serverName) |
protected boolean |
restoreAdmin() |
boolean |
restoreClusterMetrics(ClusterMetrics initial) |
protected boolean |
restoreMasters(ClusterMetrics initial,
ClusterMetrics current) |
protected boolean |
restoreRegionServers(ClusterMetrics initial,
ClusterMetrics current) |
void |
setClusterManager(org.apache.hadoop.hbase.ClusterManager clusterManager) |
void |
shutdown() |
void |
startDataNode(ServerName serverName) |
void |
startMaster(java.lang.String hostname,
int port) |
void |
startRegionServer(java.lang.String hostname,
int port) |
void |
startZkNode(java.lang.String hostname,
int port) |
void |
stopDataNode(ServerName serverName) |
void |
stopMaster(ServerName serverName) |
void |
stopRegionServer(ServerName serverName) |
void |
stopZkNode(ServerName serverName) |
boolean |
waitForActiveAndReadyMaster(long timeout) |
void |
waitForDataNodeToStart(ServerName serverName,
long timeout) |
void |
waitForDataNodeToStop(ServerName serverName,
long timeout) |
void |
waitForMasterToStop(ServerName serverName,
long timeout) |
void |
waitForRegionServerToStop(ServerName serverName,
long timeout) |
void |
waitForZkNodeToStart(ServerName serverName,
long timeout) |
void |
waitForZkNodeToStop(ServerName serverName,
long timeout) |
void |
waitUntilShutDown() |
public DistributedHBaseCluster(Configuration conf, org.apache.hadoop.hbase.ClusterManager clusterManager) throws java.io.IOException
java.io.IOException
public void setClusterManager(org.apache.hadoop.hbase.ClusterManager clusterManager)
public org.apache.hadoop.hbase.ClusterManager getClusterManager()
public ClusterMetrics getClusterMetrics() throws java.io.IOException
java.io.IOException
public ClusterMetrics getInitialClusterMetrics() throws java.io.IOException
java.io.IOException
public void close() throws java.io.IOException
java.io.IOException
public AdminProtos.AdminService.BlockingInterface getAdminProtocol(ServerName serverName) throws java.io.IOException
java.io.IOException
public ClientProtos.ClientService.BlockingInterface getClientProtocol(ServerName serverName) throws java.io.IOException
java.io.IOException
public void startRegionServer(java.lang.String hostname, int port) throws java.io.IOException
java.io.IOException
public void killRegionServer(ServerName serverName) throws java.io.IOException
java.io.IOException
public boolean isKilledRS(ServerName serverName)
public void stopRegionServer(ServerName serverName) throws java.io.IOException
java.io.IOException
public void waitForRegionServerToStop(ServerName serverName, long timeout) throws java.io.IOException
java.io.IOException
public void startZkNode(java.lang.String hostname, int port) throws java.io.IOException
java.io.IOException
public void killZkNode(ServerName serverName) throws java.io.IOException
java.io.IOException
public void stopZkNode(ServerName serverName) throws java.io.IOException
java.io.IOException
public void waitForZkNodeToStart(ServerName serverName, long timeout) throws java.io.IOException
java.io.IOException
public void waitForZkNodeToStop(ServerName serverName, long timeout) throws java.io.IOException
java.io.IOException
public void startDataNode(ServerName serverName) throws java.io.IOException
java.io.IOException
public void killDataNode(ServerName serverName) throws java.io.IOException
java.io.IOException
public void stopDataNode(ServerName serverName) throws java.io.IOException
java.io.IOException
public void waitForDataNodeToStart(ServerName serverName, long timeout) throws java.io.IOException
java.io.IOException
public void waitForDataNodeToStop(ServerName serverName, long timeout) throws java.io.IOException
java.io.IOException
public MasterService.BlockingInterface getMasterAdminService() throws java.io.IOException
java.io.IOException
public void startMaster(java.lang.String hostname, int port) throws java.io.IOException
java.io.IOException
public void killMaster(ServerName serverName) throws java.io.IOException
java.io.IOException
public void stopMaster(ServerName serverName) throws java.io.IOException
java.io.IOException
public void waitForMasterToStop(ServerName serverName, long timeout) throws java.io.IOException
java.io.IOException
public boolean waitForActiveAndReadyMaster(long timeout) throws java.io.IOException
java.io.IOException
public ServerName getServerHoldingRegion(TableName tn, byte[] regionName) throws java.io.IOException
java.io.IOException
public void waitUntilShutDown()
public void shutdown() throws java.io.IOException
java.io.IOException
public boolean isDistributedCluster()
public boolean restoreClusterMetrics(ClusterMetrics initial) throws java.io.IOException
java.io.IOException
protected boolean restoreMasters(ClusterMetrics initial, ClusterMetrics current)
protected boolean restoreRegionServers(ClusterMetrics initial, ClusterMetrics current)
protected boolean restoreAdmin() throws java.io.IOException
java.io.IOException