org.apache.hadoop.hbase

Class MiniHBaseCluster

java.lang.Object

org.apache.hadoop.hbase.HBaseCluster

org.apache.hadoop.hbase.MiniHBaseCluster

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.conf.Configurable

@InterfaceAudience.Public
public class MiniHBaseCluster
extends HBaseCluster

This class creates a single process HBase cluster. each server. The master uses the 'default' FileSystem. The RegionServers, if we are running on DistributedFilesystem, create a FileSystem instance each and will close down their instance on the way out.

Field Summary

Fields

Modifier and Type	Field and Description
LocalHBaseCluster	hbaseCluster

Fields inherited from class org.apache.hadoop.hbase.HBaseCluster

conf, initialClusterStatus

Constructor Summary

Constructors

Constructor and Description
MiniHBaseCluster(org.apache.hadoop.conf.Configuration conf, int numRegionServers) Start a MiniHBaseCluster.
MiniHBaseCluster(org.apache.hadoop.conf.Configuration conf, int numMasters, int numRegionServers) Start a MiniHBaseCluster.
MiniHBaseCluster(org.apache.hadoop.conf.Configuration conf, int numMasters, int numRegionServers, Class<? extends HMaster> masterClass, Class<? extends MiniHBaseCluster.MiniHBaseClusterRegionServer> regionserverClass) Start a MiniHBaseCluster.
MiniHBaseCluster(org.apache.hadoop.conf.Configuration conf, int numMasters, int numAlwaysStandByMasters, int numRegionServers, List<Integer> rsPorts, Class<? extends HMaster> masterClass, Class<? extends MiniHBaseCluster.MiniHBaseClusterRegionServer> regionserverClass)

Method Summary

Modifier and Type	Method and Description
String	abortMaster(int serverNumber) Cause a master to exit without shutting down entire cluster.
String	abortRegionServer(int serverNumber) Cause a region server to exit doing basic clean up only on its way out.
void	close() Closes all the resources held open for this cluster.
void	compact(boolean major) Call flushCache on all regions on all participating regionservers.
void	compact(TableName tableName, boolean major) Call flushCache on all regions of the specified table.
long	countServedRegions() Counts the total numbers of regions being served by the currently online region servers by asking each how many regions they have.
List<HRegion>	findRegionsForTable(TableName tableName)
void	flushcache() Call flushCache on all regions on all participating regionservers.
void	flushcache(TableName tableName) Call flushCache on all regions of the specified table.
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface	getAdminProtocol(ServerName serverName) Returns an AdminProtocol interface to the regionserver
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface	getClientProtocol(ServerName serverName) Returns a ClientProtocol interface to the regionserver
ClusterMetrics	getClusterMetrics() Returns a ClusterMetrics for this HBase cluster.
ClusterStatus	getClusterStatus() Deprecated. As of release 2.0.0, this will be removed in HBase 3.0.0 Use getClusterMetrics() instead.
org.apache.hadoop.conf.Configuration	getConfiguration()
List<JVMClusterUtil.MasterThread>	getLiveMasterThreads()
List<JVMClusterUtil.RegionServerThread>	getLiveRegionServerThreads()
HMaster	getMaster() Returns the current active master, if available.
HMaster	getMaster(int serverNumber) Returns the master at the specified index, if available.
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.BlockingInterface	getMasterAdminService() Returns the current active master, if available.
protected int	getMasterIndex(ServerName serverName)
JVMClusterUtil.MasterThread	getMasterThread() Returns the current active master thread, if available.
List<JVMClusterUtil.MasterThread>	getMasterThreads()
int	getNumLiveRegionServers()
List<HRegion>	getRegions(byte[] tableName)
List<HRegion>	getRegions(TableName tableName)
HRegionServer	getRegionServer(int serverNumber) Grab a numbered region server of your choice.
HRegionServer	getRegionServer(ServerName serverName)
protected int	getRegionServerIndex(ServerName serverName)
List<JVMClusterUtil.RegionServerThread>	getRegionServerThreads()
ServerName	getServerHoldingRegion(TableName tn, byte[] regionName) Get the ServerName of region server serving the specified region
int	getServerWith(byte[] regionName) Get the location of the specified region
int	getServerWithMeta()
boolean	isKilledRS(ServerName serverName) 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.
void	join() Wait for Mini HBase Cluster to shut down.
void	killAll() Do a simulated kill all masters and regionservers.
void	killDataNode(ServerName serverName) Kills the datanode process if this is a distributed cluster, otherwise, this causes master to exit doing basic clean up only.
void	killMaster(ServerName serverName) Kills the master process if this is a distributed cluster, otherwise, this causes master to exit doing basic clean up only.
void	killNameNode(ServerName serverName) Kills the namenode process if this is a distributed cluster, otherwise, this causes master to exit doing basic clean up only.
void	killRegionServer(ServerName serverName) 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	killZkNode(ServerName serverName) Kills the zookeeper node process if this is a distributed cluster, otherwise, this causes master to exit doing basic clean up only.
JVMClusterUtil.RegionServerThread	resumeRegionServer(int serverNumber) Resume the specified region server
void	resumeRegionServer(ServerName serverName) Resume the region server
void	shutdown() Shut down the mini HBase cluster
void	startDataNode(ServerName serverName) Starts a new datanode on the given hostname or if this is a mini/local cluster, silently logs warning message.
JVMClusterUtil.MasterThread	startMaster() Starts a master thread running
void	startMaster(String hostname, int port) Starts a new master on the given hostname or if this is a mini/local cluster, starts a master locally.
void	startNameNode(ServerName serverName) Starts a new namenode on the given hostname or if this is a mini/local cluster, silently logs warning message.
JVMClusterUtil.RegionServerThread	startRegionServer() Starts a region server thread running
void	startRegionServer(String hostname, int port) Starts a new region server on the given hostname or if this is a mini/local cluster, starts a region server locally.
JVMClusterUtil.RegionServerThread	startRegionServerAndWait(long timeout) Starts a region server thread and waits until its processed by master.
void	startZkNode(String hostname, int port) Starts a new zookeeper node on the given hostname or if this is a mini/local cluster, silently logs warning message.
void	stopDataNode(ServerName serverName) Stops the datanode if this is a distributed cluster, otherwise silently logs warning message.
JVMClusterUtil.MasterThread	stopMaster(int serverNumber) Shut down the specified master cleanly
JVMClusterUtil.MasterThread	stopMaster(int serverNumber, boolean shutdownFS) Shut down the specified master cleanly
void	stopMaster(ServerName serverName) Stops the given master, by attempting a gradual stop.
void	stopNameNode(ServerName serverName) Stops the namenode if this is a distributed cluster, otherwise silently logs warning message.
JVMClusterUtil.RegionServerThread	stopRegionServer(int serverNumber) Shut down the specified region server cleanly
JVMClusterUtil.RegionServerThread	stopRegionServer(int serverNumber, boolean shutdownFS) Shut down the specified region server cleanly
void	stopRegionServer(ServerName serverName) Stops the given region server, by attempting a gradual stop.
void	stopZkNode(ServerName serverName) Stops the region zookeeper if this is a distributed cluster, otherwise silently logs warning message.
JVMClusterUtil.RegionServerThread	suspendRegionServer(int serverNumber) Suspend the specified region server
void	suspendRegionServer(ServerName serverName) Suspend the region server
boolean	waitForActiveAndReadyMaster(long timeout) Blocks until there is an active master and that master has completed initialization.
void	waitForDataNodeToStart(ServerName serverName, long timeout) Wait for the specified datanode to join the cluster
void	waitForDataNodeToStop(ServerName serverName, long timeout) Wait for the specified datanode to stop the thread / process.
void	waitForMasterToStop(ServerName serverName, long timeout) Wait for the specified master to stop the thread / process.
void	waitForNameNodeToStart(ServerName serverName, long timeout) Wait for the specified namenode to join the cluster
void	waitForNameNodeToStop(ServerName serverName, long timeout) Wait for the specified namenode to stop
void	waitForRegionServerToStop(ServerName serverName, long timeout) Wait for the specified region server to stop the thread / process.
void	waitForZkNodeToStart(ServerName serverName, long timeout) Wait for the specified zookeeper node to join the cluster
void	waitForZkNodeToStop(ServerName serverName, long timeout) Wait for the specified zookeeper node to stop the thread / process.
String	waitOnMaster(int serverNumber) Wait for the specified master to stop.
String	waitOnRegionServer(int serverNumber) Wait for the specified region server to stop.
void	waitUntilShutDown() Wait for HBase Cluster to shut down.

Methods inherited from class org.apache.hadoop.hbase.HBaseCluster

getConf, getInitialClusterMetrics, getServerHoldingMeta, isDistributedCluster, restoreClusterMetrics, restoreInitialStatus, setConf, waitForActiveAndReadyMaster, waitForDatanodesRegistered, waitForNamenodeAvailable, waitForRegionServerToStart

Methods inherited from class java.lang.Object

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

Field Detail

hbaseCluster

public LocalHBaseCluster hbaseCluster

Constructor Detail

MiniHBaseCluster

public MiniHBaseCluster(org.apache.hadoop.conf.Configuration conf,
                        int numRegionServers)
                 throws IOException,
                        InterruptedException

Start a MiniHBaseCluster.

Parameters:

conf - Configuration to be used for cluster

numRegionServers - initial number of region servers to start.

Throws:

IOException

InterruptedException

MiniHBaseCluster

public MiniHBaseCluster(org.apache.hadoop.conf.Configuration conf,
                        int numMasters,
                        int numRegionServers)
                 throws IOException,
                        InterruptedException

Start a MiniHBaseCluster.

Parameters:

conf - Configuration to be used for cluster

numMasters - initial number of masters to start.

numRegionServers - initial number of region servers to start.

Throws:

IOException

InterruptedException

MiniHBaseCluster

public MiniHBaseCluster(org.apache.hadoop.conf.Configuration conf,
                        int numMasters,
                        int numRegionServers,
                        Class<? extends HMaster> masterClass,
                        Class<? extends MiniHBaseCluster.MiniHBaseClusterRegionServer> regionserverClass)
                 throws IOException,
                        InterruptedException

Start a MiniHBaseCluster.

Parameters:

conf - Configuration to be used for cluster

numMasters - initial number of masters to start.

numRegionServers - initial number of region servers to start.

Throws:

IOException

InterruptedException

MiniHBaseCluster

public MiniHBaseCluster(org.apache.hadoop.conf.Configuration conf,
                        int numMasters,
                        int numAlwaysStandByMasters,
                        int numRegionServers,
                        List<Integer> rsPorts,
                        Class<? extends HMaster> masterClass,
                        Class<? extends MiniHBaseCluster.MiniHBaseClusterRegionServer> regionserverClass)
                 throws IOException,
                        InterruptedException

Parameters:

rsPorts - Ports that RegionServer should use; pass ports if you want to test cluster restart where for sure the regionservers come up on same address+port (but just with different startcode); by default mini hbase clusters choose new arbitrary ports on each cluster start.

Throws:

IOException

InterruptedException

Method Detail

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration()

startRegionServer

public void startRegionServer(String hostname,
                              int port)
                       throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Starts a new region server on the given hostname or if this is a mini/local cluster, starts a region server locally.

Specified by:

startRegionServer in class HBaseCluster

Parameters:

hostname - the hostname to start the regionserver on

Throws:

IOException - if something goes wrong

killRegionServer

public void killRegionServer(ServerName serverName)
                      throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Kills the region server process if this is a distributed cluster, otherwise this causes the region server to exit doing basic clean up only.

Specified by:

killRegionServer in class HBaseCluster

Throws:

IOException - if something goes wrong

isKilledRS

public boolean isKilledRS(ServerName serverName)

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

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. A concrete example of such case is - killing servers and waiting for all regions of a particular table to be assigned. We can check for server column in META table and that its value is not one of the killed servers.

Specified by:

isKilledRS in class HBaseCluster

stopRegionServer

public void stopRegionServer(ServerName serverName)
                      throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Stops the given region server, by attempting a gradual stop.

Specified by:

stopRegionServer in class HBaseCluster

Throws:

IOException - if something goes wrong

suspendRegionServer

public void suspendRegionServer(ServerName serverName)
                         throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Suspend the region server

Specified by:

suspendRegionServer in class HBaseCluster

Parameters:

serverName - the hostname to suspend the regionserver on

Throws:

IOException - if something goes wrong

resumeRegionServer

public void resumeRegionServer(ServerName serverName)
                        throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Resume the region server

Specified by:

resumeRegionServer in class HBaseCluster

Parameters:

serverName - the hostname to resume the regionserver on

Throws:

IOException - if something goes wrong

waitForRegionServerToStop

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

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Wait for the specified region server to stop the thread / process.

Specified by:

waitForRegionServerToStop in class HBaseCluster

Throws:

IOException - if something goes wrong or timeout occurs

startZkNode

public void startZkNode(String hostname,
                        int port)
                 throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Starts a new zookeeper node on the given hostname or if this is a mini/local cluster, silently logs warning message.

Specified by:

startZkNode in class HBaseCluster

Parameters:

hostname - the hostname to start the regionserver on

Throws:

IOException - if something goes wrong

killZkNode

public void killZkNode(ServerName serverName)
                throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Kills the zookeeper node process if this is a distributed cluster, otherwise, this causes master to exit doing basic clean up only.

Specified by:

killZkNode in class HBaseCluster

Throws:

IOException - if something goes wrong

stopZkNode

public void stopZkNode(ServerName serverName)
                throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Stops the region zookeeper if this is a distributed cluster, otherwise silently logs warning message.

Specified by:

stopZkNode in class HBaseCluster

Throws:

IOException - if something goes wrong

waitForZkNodeToStart

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

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Wait for the specified zookeeper node to join the cluster

Specified by:

waitForZkNodeToStart in class HBaseCluster

Throws:

IOException - if something goes wrong or timeout occurs

waitForZkNodeToStop

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

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Wait for the specified zookeeper node to stop the thread / process.

Specified by:

waitForZkNodeToStop in class HBaseCluster

Throws:

IOException - if something goes wrong or timeout occurs

startDataNode

public void startDataNode(ServerName serverName)
                   throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Starts a new datanode on the given hostname or if this is a mini/local cluster, silently logs warning message.

Specified by:

startDataNode in class HBaseCluster

Throws:

IOException - if something goes wrong

killDataNode

public void killDataNode(ServerName serverName)
                  throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Kills the datanode process if this is a distributed cluster, otherwise, this causes master to exit doing basic clean up only.

Specified by:

killDataNode in class HBaseCluster

Throws:

IOException - if something goes wrong

stopDataNode

public void stopDataNode(ServerName serverName)
                  throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Stops the datanode if this is a distributed cluster, otherwise silently logs warning message.

Specified by:

stopDataNode in class HBaseCluster

Throws:

IOException - if something goes wrong

waitForDataNodeToStart

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

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Wait for the specified datanode to join the cluster

Specified by:

waitForDataNodeToStart in class HBaseCluster

Throws:

IOException - if something goes wrong or timeout occurs

waitForDataNodeToStop

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

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Wait for the specified datanode to stop the thread / process.

Specified by:

waitForDataNodeToStop in class HBaseCluster

Throws:

IOException - if something goes wrong or timeout occurs

startNameNode

public void startNameNode(ServerName serverName)
                   throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Starts a new namenode on the given hostname or if this is a mini/local cluster, silently logs warning message.

Specified by:

startNameNode in class HBaseCluster

Throws:

IOException - if something goes wrong

killNameNode

public void killNameNode(ServerName serverName)
                  throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Kills the namenode process if this is a distributed cluster, otherwise, this causes master to exit doing basic clean up only.

Specified by:

killNameNode in class HBaseCluster

Throws:

IOException - if something goes wrong

stopNameNode

public void stopNameNode(ServerName serverName)
                  throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Stops the namenode if this is a distributed cluster, otherwise silently logs warning message.

Specified by:

stopNameNode in class HBaseCluster

Throws:

IOException - if something goes wrong

waitForNameNodeToStart

public void waitForNameNodeToStart(ServerName serverName,
                                   long timeout)
                            throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Wait for the specified namenode to join the cluster

Specified by:

waitForNameNodeToStart in class HBaseCluster

Throws:

IOException - if something goes wrong or timeout occurs

waitForNameNodeToStop

public void waitForNameNodeToStop(ServerName serverName,
                                  long timeout)
                           throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Wait for the specified namenode to stop

Specified by:

waitForNameNodeToStop in class HBaseCluster

Throws:

IOException - if something goes wrong or timeout occurs

startMaster

public void startMaster(String hostname,
                        int port)
                 throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Starts a new master on the given hostname or if this is a mini/local cluster, starts a master locally.

Specified by:

startMaster in class HBaseCluster

Parameters:

hostname - the hostname to start the master on

Throws:

IOException - if something goes wrong

killMaster

public void killMaster(ServerName serverName)
                throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Kills the master process if this is a distributed cluster, otherwise, this causes master to exit doing basic clean up only.

Specified by:

killMaster in class HBaseCluster

Throws:

IOException - if something goes wrong

stopMaster

public void stopMaster(ServerName serverName)
                throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Stops the given master, by attempting a gradual stop.

Specified by:

stopMaster in class HBaseCluster

Throws:

IOException - if something goes wrong

waitForMasterToStop

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

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Wait for the specified master to stop the thread / process.

Specified by:

waitForMasterToStop in class HBaseCluster

Throws:

IOException - if something goes wrong or timeout occurs

startRegionServer

public JVMClusterUtil.RegionServerThread startRegionServer()
                                                    throws IOException

Starts a region server thread running

Returns:

New RegionServerThread

Throws:

IOException

startRegionServerAndWait

public JVMClusterUtil.RegionServerThread startRegionServerAndWait(long timeout)
                                                           throws IOException

Starts a region server thread and waits until its processed by master. Throws an exception when it can't start a region server or when the region server is not processed by master within the timeout.

Returns:

New RegionServerThread

Throws:

IOException

abortRegionServer

public String abortRegionServer(int serverNumber)

Cause a region server to exit doing basic clean up only on its way out.

Parameters:

serverNumber - Used as index into a list.

stopRegionServer

public JVMClusterUtil.RegionServerThread stopRegionServer(int serverNumber)

Shut down the specified region server cleanly

Parameters:

serverNumber - Used as index into a list.

Returns:

the region server that was stopped

stopRegionServer

public JVMClusterUtil.RegionServerThread stopRegionServer(int serverNumber,
                                                          boolean shutdownFS)

Shut down the specified region server cleanly

Parameters:

serverNumber - Used as index into a list.

shutdownFS - True is we are to shutdown the filesystem as part of this regionserver's shutdown. Usually we do but you do not want to do this if you are running multiple regionservers in a test and you shut down one before end of the test.

Returns:

the region server that was stopped

suspendRegionServer

public JVMClusterUtil.RegionServerThread suspendRegionServer(int serverNumber)

Suspend the specified region server

Parameters:

serverNumber - Used as index into a list.

Returns:

resumeRegionServer

public JVMClusterUtil.RegionServerThread resumeRegionServer(int serverNumber)

Resume the specified region server

Parameters:

serverNumber - Used as index into a list.

Returns:

waitOnRegionServer

public String waitOnRegionServer(int serverNumber)

Wait for the specified region server to stop. Removes this thread from list of running threads.

Parameters:

serverNumber -

Returns:

Name of region server that just went down.

startMaster

public JVMClusterUtil.MasterThread startMaster()
                                        throws IOException

Starts a master thread running

Returns:

New RegionServerThread

Throws:

IOException

getMasterAdminService

public org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.BlockingInterface getMasterAdminService()

Returns the current active master, if available.

Specified by:

getMasterAdminService in class HBaseCluster

Returns:

the active HMaster, null if none is active.

getMaster

public HMaster getMaster()

Returns the current active master, if available.

Returns:

the active HMaster, null if none is active.

getMasterThread

public JVMClusterUtil.MasterThread getMasterThread()

Returns the current active master thread, if available.

Returns:

the active MasterThread, null if none is active.

getMaster

public HMaster getMaster(int serverNumber)

Returns the master at the specified index, if available.

Returns:

the active HMaster, null if none is active.

abortMaster

public String abortMaster(int serverNumber)

Cause a master to exit without shutting down entire cluster.

Parameters:

serverNumber - Used as index into a list.

stopMaster

public JVMClusterUtil.MasterThread stopMaster(int serverNumber)

Shut down the specified master cleanly

Parameters:

serverNumber - Used as index into a list.

Returns:

the region server that was stopped

stopMaster

public JVMClusterUtil.MasterThread stopMaster(int serverNumber,
                                              boolean shutdownFS)

Shut down the specified master cleanly

Parameters:

serverNumber - Used as index into a list.

shutdownFS - True is we are to shutdown the filesystem as part of this master's shutdown. Usually we do but you do not want to do this if you are running multiple master in a test and you shut down one before end of the test.

Returns:

the master that was stopped

waitOnMaster

public String waitOnMaster(int serverNumber)

Wait for the specified master to stop. Removes this thread from list of running threads.

Parameters:

serverNumber -

Returns:

Name of master that just went down.

waitForActiveAndReadyMaster

public boolean waitForActiveAndReadyMaster(long timeout)
                                    throws IOException

Blocks until there is an active master and that master has completed initialization.

Specified by:

waitForActiveAndReadyMaster in class HBaseCluster

Parameters:

timeout - the timeout limit in ms

Returns:

true if an active master becomes available. false if there are no masters left.

Throws:

InterruptedException

IOException

getMasterThreads

public List<JVMClusterUtil.MasterThread> getMasterThreads()

Returns:

List of master threads.

getLiveMasterThreads

public List<JVMClusterUtil.MasterThread> getLiveMasterThreads()

Returns:

List of live master threads (skips the aborted and the killed)

join

public void join()

Wait for Mini HBase Cluster to shut down.

shutdown

public void shutdown()
              throws IOException

Shut down the mini HBase cluster

Specified by:

shutdown in class HBaseCluster

Throws:

IOException

close

public void close()
           throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Closes all the resources held open for this cluster. Note that this call does not shutdown the cluster.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in class HBaseCluster

Throws:

IOException

See Also:

HBaseCluster.shutdown()

getClusterStatus

@Deprecated
public ClusterStatus getClusterStatus()
                                           throws IOException

Deprecated. As of release 2.0.0, this will be removed in HBase 3.0.0 Use getClusterMetrics() instead.

Throws:

IOException

getClusterMetrics

public ClusterMetrics getClusterMetrics()
                                 throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Returns a ClusterMetrics for this HBase cluster.

Specified by:

getClusterMetrics in class HBaseCluster

Throws:

IOException

See Also:

HBaseCluster.getInitialClusterMetrics()

flushcache

public void flushcache()
                throws IOException

Call flushCache on all regions on all participating regionservers.

Throws:

IOException

flushcache

public void flushcache(TableName tableName)
                throws IOException

Call flushCache on all regions of the specified table.

Throws:

IOException

compact

public void compact(boolean major)
             throws IOException

Call flushCache on all regions on all participating regionservers.

Throws:

IOException

compact

public void compact(TableName tableName,
                    boolean major)
             throws IOException

Call flushCache on all regions of the specified table.

Throws:

IOException

getNumLiveRegionServers

public int getNumLiveRegionServers()

Returns:

Number of live region servers in the cluster currently.

getRegionServerThreads

public List<JVMClusterUtil.RegionServerThread> getRegionServerThreads()

Returns:

List of region server threads. Does not return the master even though it is also a region server.

getLiveRegionServerThreads

public List<JVMClusterUtil.RegionServerThread> getLiveRegionServerThreads()

Returns:

List of live region server threads (skips the aborted and the killed)

getRegionServer

public HRegionServer getRegionServer(int serverNumber)

Grab a numbered region server of your choice.

Parameters:

serverNumber -

Returns:

region server

getRegionServer

public HRegionServer getRegionServer(ServerName serverName)

getRegions

public List<HRegion> getRegions(byte[] tableName)

getRegions

public List<HRegion> getRegions(TableName tableName)

getServerWithMeta

public int getServerWithMeta()

Returns:

Index into List of getRegionServerThreads() of HRS carrying regionName. Returns -1 if none found.

getServerWith

public int getServerWith(byte[] regionName)

Get the location of the specified region

Parameters:

regionName - Name of the region in bytes

Returns:

Index into List of getRegionServerThreads() of HRS carrying hbase:meta. Returns -1 if none found.

getServerHoldingRegion

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

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Get the ServerName of region server serving the specified region

Specified by:

getServerHoldingRegion in class HBaseCluster

Parameters:

tn - Table name that has the region.

regionName - Name of the region in bytes

Returns:

ServerName that hosts the region or null

Throws:

IOException

countServedRegions

public long countServedRegions()

Counts the total numbers of regions being served by the currently online region servers by asking each how many regions they have. Does not look at hbase:meta at all. Count includes catalog tables.

Returns:

number of regions being served by all region servers

killAll

public void killAll()

Do a simulated kill all masters and regionservers. Useful when it is impossible to bring the mini-cluster back for clean shutdown.

waitUntilShutDown

public void waitUntilShutDown()

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Wait for HBase Cluster to shut down.

Specified by:

waitUntilShutDown in class HBaseCluster

findRegionsForTable

public List<HRegion> findRegionsForTable(TableName tableName)

getRegionServerIndex

protected int getRegionServerIndex(ServerName serverName)

getMasterIndex

protected int getMasterIndex(ServerName serverName)

getAdminProtocol

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface getAdminProtocol(ServerName serverName)
                                                                                                              throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Returns an AdminProtocol interface to the regionserver

Specified by:

getAdminProtocol in class HBaseCluster

Throws:

IOException

getClientProtocol

public org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface getClientProtocol(ServerName serverName)
                                                                                                                 throws IOException

Description copied from class: org.apache.hadoop.hbase.HBaseCluster

Returns a ClientProtocol interface to the regionserver

Specified by:

getClientProtocol in class HBaseCluster

Throws:

IOException