org.apache.hadoop.hbase.zookeeper

Class MiniZooKeeperCluster

java.lang.Object

org.apache.hadoop.hbase.zookeeper.MiniZooKeeperCluster

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public class MiniZooKeeperCluster
extends java.lang.Object

TODO: Most of the code in this class is ripped from ZooKeeper tests. Instead of redoing it, we should contribute updates to their code which let us more easily access testing helper objects.

Constructor Summary

Constructors

Constructor and Description
MiniZooKeeperCluster()
MiniZooKeeperCluster(Configuration configuration)

Method Summary

Modifier and Type	Method and Description
void	addClientPort(int clientPort) Add a client port to the list.
int	getBackupZooKeeperServerNum()
int	getClientPort()
java.util.List<java.lang.Integer>	getClientPortList() Get the list of client ports.
int	getZooKeeperServerNum()
int	killCurrentActiveZooKeeperServer()
void	killOneBackupZooKeeperServer() Kill one back up ZK servers
void	setDefaultClientPort(int clientPort)
void	setTickTime(int tickTime)
void	shutdown()
int	startup(java.io.File baseDir)
int	startup(java.io.File baseDir, int numZooKeeperServers)

Methods inherited from class java.lang.Object

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

Constructor Detail

MiniZooKeeperCluster

public MiniZooKeeperCluster()

MiniZooKeeperCluster

public MiniZooKeeperCluster(Configuration configuration)

Method Detail

addClientPort

public void addClientPort(int clientPort)

Add a client port to the list.

Parameters:

clientPort - the specified port

getClientPortList

public java.util.List<java.lang.Integer> getClientPortList()

Get the list of client ports.

Returns:

clientPortList the client port list

setDefaultClientPort

public void setDefaultClientPort(int clientPort)

setTickTime

public void setTickTime(int tickTime)

getBackupZooKeeperServerNum

public int getBackupZooKeeperServerNum()

getZooKeeperServerNum

public int getZooKeeperServerNum()

startup

public int startup(java.io.File baseDir)
            throws java.io.IOException,
                   java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

startup

public int startup(java.io.File baseDir,
                   int numZooKeeperServers)
            throws java.io.IOException,
                   java.lang.InterruptedException

Parameters:

baseDir -

numZooKeeperServers -

Returns:

ClientPort server bound to, -1 if there was a binding problem and we couldn't pick another port.

Throws:

java.io.IOException

java.lang.InterruptedException

shutdown

public void shutdown()
              throws java.io.IOException

Throws:

java.io.IOException

killCurrentActiveZooKeeperServer

public int killCurrentActiveZooKeeperServer()
                                     throws java.io.IOException,
                                            java.lang.InterruptedException

Returns:

clientPort return clientPort if there is another ZK backup can run when killing the current active; return -1, if there is no backups.

Throws:

java.io.IOException

java.lang.InterruptedException

killOneBackupZooKeeperServer

public void killOneBackupZooKeeperServer()
                                  throws java.io.IOException,
                                         java.lang.InterruptedException

Kill one back up ZK servers

Throws:

java.io.IOException

java.lang.InterruptedException

getClientPort

public int getClientPort()