org.apache.hadoop.hbase.util

Class ProcessBasedLocalHBaseCluster

java.lang.Object

org.apache.hadoop.hbase.util.ProcessBasedLocalHBaseCluster

public class ProcessBasedLocalHBaseCluster
extends Object

A helper class for process-based mini-cluster tests. Unlike MiniHBaseCluster, starts daemons as separate processes, allowing to do real kill testing.

Constructor Summary

Constructors

Constructor and Description
ProcessBasedLocalHBaseCluster(Configuration conf, int numDataNodes, int numRegionServers) Constructor.

Method Summary

Modifier and Type	Method and Description
Configuration	getConf()
void	killMaster()
void	killRegionServer(int port)
void	shutdown()
void	startHBase()
void	startMaster(int port)
void	startMiniDFS() Makes this local HBase cluster use a mini-DFS cluster.
void	startRegionServer(int port)
void	startZK()

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcessBasedLocalHBaseCluster

public ProcessBasedLocalHBaseCluster(Configuration conf,
                                     int numDataNodes,
                                     int numRegionServers)

Constructor. Modifies the passed configuration.

Parameters:

hbaseHome - the top directory of the HBase source tree

Method Detail

startMiniDFS

public void startMiniDFS()
                  throws Exception

Makes this local HBase cluster use a mini-DFS cluster. Must be called before startHBase().

Throws:

IOException

Exception

startHBase

public void startHBase()
                throws IOException

Throws:

IOException

startRegionServer

public void startRegionServer(int port)

startMaster

public void startMaster(int port)

killRegionServer

public void killRegionServer(int port)
                      throws IOException

Throws:

IOException

killMaster

public void killMaster()
                throws IOException

Throws:

IOException

startZK

public void startZK()

getConf

public Configuration getConf()

shutdown

public void shutdown()