Constructor Detail

• MiniZooKeeperCluster

  public MiniZooKeeperCluster()

• MiniZooKeeperCluster

  public MiniZooKeeperCluster(org.apache.hadoop.conf.Configuration configuration)

Method Detail

• addClientPort

  public void addClientPort(int clientPort)

  Add a client port to the list.

  Parameters:

  clientPort - the specified port

• getClientPortList

  public List<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(File baseDir)
              throws IOException,
                     InterruptedException

  Throws:

  IOException

  InterruptedException

• startup

  public int startup(File baseDir,
            int numZooKeeperServers)
              throws IOException,
                     InterruptedException

  Parameters:

  baseDir -

  numZooKeeperServers -

  Returns:

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

  Throws:

  IOException

  InterruptedException

• shutdown

  public void shutdown()
                throws IOException

  Throws:

  IOException

• killCurrentActiveZooKeeperServer

  public int killCurrentActiveZooKeeperServer()
                                       throws IOException,
                                              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:

  IOException

  InterruptedException

• killOneBackupZooKeeperServer

  public void killOneBackupZooKeeperServer()
                                    throws IOException,
                                           InterruptedException

  Kill one back up ZK servers

  Throws:

  IOException

  InterruptedException

• getClientPort

  public int getClientPort()