org.apache.hadoop.hbase

Class DistributedHBaseCluster

java.lang.Object

HBaseCluster

org.apache.hadoop.hbase.DistributedHBaseCluster

public class DistributedHBaseCluster
extends HBaseCluster

Manages the interactions with an already deployed distributed cluster (as opposed to a pseudo-distributed, or mini/local cluster). This is used by integration and system tests.

Constructor Summary

Constructors

Constructor and Description
DistributedHBaseCluster(Configuration conf, org.apache.hadoop.hbase.ClusterManager clusterManager)

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DistributedHBaseCluster

public DistributedHBaseCluster(Configuration conf,
                               org.apache.hadoop.hbase.ClusterManager clusterManager)
                        throws java.io.IOException

Throws:

java.io.IOException

Method Detail

setClusterManager

public void setClusterManager(org.apache.hadoop.hbase.ClusterManager clusterManager)

getClusterManager

public org.apache.hadoop.hbase.ClusterManager getClusterManager()

getClusterMetrics

public ClusterMetrics getClusterMetrics()
                                 throws java.io.IOException

Returns a ClusterStatus for this HBase cluster

Throws:

java.io.IOException

getInitialClusterMetrics

public ClusterMetrics getInitialClusterMetrics()
                                        throws java.io.IOException

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

getAdminProtocol

public AdminProtos.AdminService.BlockingInterface getAdminProtocol(ServerName serverName)
                                                            throws java.io.IOException

Throws:

java.io.IOException

getClientProtocol

public ClientProtos.ClientService.BlockingInterface getClientProtocol(ServerName serverName)
                                                               throws java.io.IOException

Throws:

java.io.IOException

startRegionServer

public void startRegionServer(java.lang.String hostname,
                              int port)
                       throws java.io.IOException

Throws:

java.io.IOException

killRegionServer

public void killRegionServer(ServerName serverName)
                      throws java.io.IOException

Throws:

java.io.IOException

isKilledRS

public boolean isKilledRS(ServerName serverName)

stopRegionServer

public void stopRegionServer(ServerName serverName)
                      throws java.io.IOException

Throws:

java.io.IOException

waitForRegionServerToStop

public void waitForRegionServerToStop(ServerName serverName,
                                      long timeout)
                               throws java.io.IOException

Throws:

java.io.IOException

startZkNode

public void startZkNode(java.lang.String hostname,
                        int port)
                 throws java.io.IOException

Throws:

java.io.IOException

killZkNode

public void killZkNode(ServerName serverName)
                throws java.io.IOException

Throws:

java.io.IOException

stopZkNode

public void stopZkNode(ServerName serverName)
                throws java.io.IOException

Throws:

java.io.IOException

waitForZkNodeToStart

public void waitForZkNodeToStart(ServerName serverName,
                                 long timeout)
                          throws java.io.IOException

Throws:

java.io.IOException

waitForZkNodeToStop

public void waitForZkNodeToStop(ServerName serverName,
                                long timeout)
                         throws java.io.IOException

Throws:

java.io.IOException

startDataNode

public void startDataNode(ServerName serverName)
                   throws java.io.IOException

Throws:

java.io.IOException

killDataNode

public void killDataNode(ServerName serverName)
                  throws java.io.IOException

Throws:

java.io.IOException

stopDataNode

public void stopDataNode(ServerName serverName)
                  throws java.io.IOException

Throws:

java.io.IOException

waitForDataNodeToStart

public void waitForDataNodeToStart(ServerName serverName,
                                   long timeout)
                            throws java.io.IOException

Throws:

java.io.IOException

waitForDataNodeToStop

public void waitForDataNodeToStop(ServerName serverName,
                                  long timeout)
                           throws java.io.IOException

Throws:

java.io.IOException

getMasterAdminService

public MasterService.BlockingInterface getMasterAdminService()
                                                      throws java.io.IOException

Throws:

java.io.IOException

startMaster

public void startMaster(java.lang.String hostname,
                        int port)
                 throws java.io.IOException

Throws:

java.io.IOException

killMaster

public void killMaster(ServerName serverName)
                throws java.io.IOException

Throws:

java.io.IOException

stopMaster

public void stopMaster(ServerName serverName)
                throws java.io.IOException

Throws:

java.io.IOException

waitForMasterToStop

public void waitForMasterToStop(ServerName serverName,
                                long timeout)
                         throws java.io.IOException

Throws:

java.io.IOException

waitForActiveAndReadyMaster

public boolean waitForActiveAndReadyMaster(long timeout)
                                    throws java.io.IOException

Throws:

java.io.IOException

getServerHoldingRegion

public ServerName getServerHoldingRegion(TableName tn,
                                         byte[] regionName)
                                  throws java.io.IOException

Throws:

java.io.IOException

waitUntilShutDown

public void waitUntilShutDown()

shutdown

public void shutdown()
              throws java.io.IOException

Throws:

java.io.IOException

isDistributedCluster

public boolean isDistributedCluster()

restoreClusterMetrics

public boolean restoreClusterMetrics(ClusterMetrics initial)
                              throws java.io.IOException

Throws:

java.io.IOException

restoreMasters

protected boolean restoreMasters(ClusterMetrics initial,
                                 ClusterMetrics current)

restoreRegionServers

protected boolean restoreRegionServers(ClusterMetrics initial,
                                       ClusterMetrics current)

restoreAdmin

protected boolean restoreAdmin()
                        throws java.io.IOException

Throws:

java.io.IOException