org.apache.drill.exec

Class ZookeeperHelper

java.lang.Object

org.apache.drill.exec.ZookeeperHelper

public class ZookeeperHelper
extends Object

Test utility for managing a Zookeeper instance.

Tests that need a Zookeeper instance can initialize a static instance of this class in their BeforeClass section to set up Zookeeper.

Modified to also work in the ClusterFixture class. The "bare" use sets up a Drill config. The use in the cluster fixture delegates to the cluster fixture the task of setting up the Drill config. In the "bare" case, the port number comes from the Drill config. In the cluster fixture case, we let ZK choose the port and we learn what it is. As a result, the code is a bit more cluttered than if we could just use the class for one purpose.

Constructor Summary

Constructors

Constructor and Description
ZookeeperHelper() Constructor.
ZookeeperHelper(boolean failureInCancelled, boolean autoPort) Constructor.

Method Summary

Modifier and Type	Method and Description
DrillConfig	getConfig() Get the DrillConfig used for the Zookeeper instance.
String	getConnectionString()
void	startZookeeper(int numServers) Start the Zookeeper instance.
void	stopZookeeper() Shut down the Zookeeper instance.

Methods inherited from class java.lang.Object

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

Constructor Detail

ZookeeperHelper

public ZookeeperHelper()

Constructor.

Will create a "test-data" directory for Zookeeper's use if one doesn't already exist.

ZookeeperHelper

public ZookeeperHelper(boolean failureInCancelled,
                       boolean autoPort)

Constructor.

Will create a "test-data" directory for Zookeeper's use if one doesn't already exist.

Parameters:

failureInCancelled - pass true if you want failures in cancelled fragments to be reported as failures

Method Detail

startZookeeper

public void startZookeeper(int numServers)

Start the Zookeeper instance.

This must be used before any operations that depend on the Zookeeper instance being up.

Parameters:

numServers - how many servers the Zookeeper instance should have

stopZookeeper

public void stopZookeeper()

Shut down the Zookeeper instance.

This must be used before the program exits.

getConfig

public DrillConfig getConfig()

Get the DrillConfig used for the Zookeeper instance.

Returns:

the DrillConfig used.

getConnectionString

public String getConnectionString()