org.apache.drill.exec.util

Class MiniZooKeeperCluster

java.lang.Object

org.apache.drill.exec.util.MiniZooKeeperCluster

public class MiniZooKeeperCluster
extends Object

Mostly Copied from HBase's MiniZooKeeperCluster, but without the Hadoop dependency.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_PORT

Constructor Summary

Constructors

Constructor and Description
MiniZooKeeperCluster()

Method Summary

Modifier and Type	Method and Description
int	getBackupZooKeeperServerNum()
int	getClientPort()
int	getZooKeeperServerNum()
int	killCurrentActiveZooKeeperServer()
void	killOneBackupZooKeeperServer() Kill one back up ZK servers
void	setDefaultClientPort(int clientPort)
void	setTickTime(int tickTime)
void	shutdown()
int	startup(File baseDir)
int	startup(File baseDir, int numZooKeeperServers)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_PORT

public static final int DEFAULT_PORT

See Also:

Constant Field Values

Constructor Detail

MiniZooKeeperCluster

public MiniZooKeeperCluster()

Method Detail

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.

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()