@InterfaceAudience.Public @InterfaceStability.Evolving public class LocalHBaseCluster extends java.lang.Object
startup()
to start the cluster running and shutdown()
to close it all down. join()
the cluster is you want to wait on
shutdown completion.
Runs master on port 16000 by default. Because we can't just kill the process -- not till HADOOP-1700 gets fixed and even then.... -- we need to be able to find the master with a remote client to run shutdown. To use a port other than 16000, set the hbase.master to a value of 'local:PORT': that is 'local', not 'localhost', and the port number the master should use instead of 16000.
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
LOCAL
local mode
|
static java.lang.String |
LOCAL_COLON
'local:'
|
Constructor and Description |
---|
LocalHBaseCluster(Configuration conf)
Constructor.
|
LocalHBaseCluster(Configuration conf,
int noRegionServers)
Constructor.
|
LocalHBaseCluster(Configuration conf,
int noMasters,
int noRegionServers)
Constructor.
|
LocalHBaseCluster(Configuration conf,
int noMasters,
int noRegionServers,
java.lang.Class<? extends HMaster> masterClass,
java.lang.Class<? extends HRegionServer> regionServerClass)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
JVMClusterUtil.MasterThread |
addMaster() |
JVMClusterUtil.MasterThread |
addMaster(Configuration c,
int index) |
JVMClusterUtil.MasterThread |
addMaster(Configuration c,
int index,
User user) |
JVMClusterUtil.RegionServerThread |
addRegionServer() |
JVMClusterUtil.RegionServerThread |
addRegionServer(Configuration config,
int index) |
JVMClusterUtil.RegionServerThread |
addRegionServer(Configuration config,
int index,
User user) |
HMaster |
getActiveMaster()
Gets the current active master, if available.
|
Configuration |
getConfiguration() |
java.util.List<JVMClusterUtil.MasterThread> |
getLiveMasters() |
java.util.List<JVMClusterUtil.RegionServerThread> |
getLiveRegionServers() |
HMaster |
getMaster(int serverNumber) |
java.util.List<JVMClusterUtil.MasterThread> |
getMasters() |
HRegionServer |
getRegionServer(int serverNumber) |
java.util.List<JVMClusterUtil.RegionServerThread> |
getRegionServers() |
static boolean |
isLocal(Configuration c) |
void |
join()
Wait for Mini HBase Cluster to shut down.
|
static void |
main(java.lang.String[] args)
Test things basically work.
|
void |
shutdown()
Shut down the mini HBase cluster
|
void |
startup()
Start the cluster.
|
java.lang.String |
waitOnMaster(int serverNumber)
Wait for the specified master to stop
Removes this thread from list of running threads.
|
java.lang.String |
waitOnMaster(JVMClusterUtil.MasterThread masterThread)
Wait for the specified master to stop
Removes this thread from list of running threads.
|
java.lang.String |
waitOnRegionServer(int serverNumber)
Wait for the specified region server to stop
Removes this thread from list of running threads.
|
java.lang.String |
waitOnRegionServer(JVMClusterUtil.RegionServerThread rst)
Wait for the specified region server to stop
Removes this thread from list of running threads.
|
public static final java.lang.String LOCAL
public static final java.lang.String LOCAL_COLON
public LocalHBaseCluster(Configuration conf) throws java.io.IOException
conf
- java.io.IOException
public LocalHBaseCluster(Configuration conf, int noRegionServers) throws java.io.IOException
conf
- Configuration to use. Post construction has the master's
address.noRegionServers
- Count of regionservers to start.java.io.IOException
public LocalHBaseCluster(Configuration conf, int noMasters, int noRegionServers) throws java.io.IOException
conf
- Configuration to use. Post construction has the active master
address.noMasters
- Count of masters to start.noRegionServers
- Count of regionservers to start.java.io.IOException
public LocalHBaseCluster(Configuration conf, int noMasters, int noRegionServers, java.lang.Class<? extends HMaster> masterClass, java.lang.Class<? extends HRegionServer> regionServerClass) throws java.io.IOException
conf
- Configuration to use. Post construction has the master's
address.noMasters
- Count of masters to start.noRegionServers
- Count of regionservers to start.masterClass
- regionServerClass
- java.io.IOException
public JVMClusterUtil.RegionServerThread addRegionServer() throws java.io.IOException
java.io.IOException
public JVMClusterUtil.RegionServerThread addRegionServer(Configuration config, int index) throws java.io.IOException
java.io.IOException
public JVMClusterUtil.RegionServerThread addRegionServer(Configuration config, int index, User user) throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public JVMClusterUtil.MasterThread addMaster() throws java.io.IOException
java.io.IOException
public JVMClusterUtil.MasterThread addMaster(Configuration c, int index) throws java.io.IOException
java.io.IOException
public JVMClusterUtil.MasterThread addMaster(Configuration c, int index, User user) throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public HRegionServer getRegionServer(int serverNumber)
serverNumber
- public java.util.List<JVMClusterUtil.RegionServerThread> getRegionServers()
public java.util.List<JVMClusterUtil.RegionServerThread> getLiveRegionServers()
public Configuration getConfiguration()
public java.lang.String waitOnRegionServer(int serverNumber)
serverNumber
- public java.lang.String waitOnRegionServer(JVMClusterUtil.RegionServerThread rst)
rst
- public HMaster getMaster(int serverNumber)
serverNumber
- public HMaster getActiveMaster()
public java.util.List<JVMClusterUtil.MasterThread> getMasters()
public java.util.List<JVMClusterUtil.MasterThread> getLiveMasters()
public java.lang.String waitOnMaster(int serverNumber)
serverNumber
- public java.lang.String waitOnMaster(JVMClusterUtil.MasterThread masterThread)
masterThread
- public void join()
shutdown()
.public void startup() throws java.io.IOException
java.io.IOException
public void shutdown()
public static boolean isLocal(Configuration c)
c
- Configuration to check.public static void main(java.lang.String[] args) throws java.io.IOException
args
- java.io.IOException