org.trafodion.dcs.zookeeper

Class ZKConfig

java.lang.Object

org.trafodion.dcs.zookeeper.ZKConfig

public class ZKConfig
extends Object

Utility methods for reading, parsing, and building zookeeper configuration.

Constructor Summary

Constructors

Constructor and Description
ZKConfig()

Method Summary

Methods

Modifier and Type	Method and Description
static String	getZKQuorumServersString(org.apache.hadoop.conf.Configuration conf) Return the ZK Quorum servers string given the specified configuration.
static String	getZKQuorumServersString(Properties properties) Return the ZK Quorum servers string given zk properties returned by makeZKProps
static Properties	makeZKProps(org.apache.hadoop.conf.Configuration conf) Make a Properties object holding ZooKeeper config equivalent to zoo.cfg.
static Properties	parseZooCfg(org.apache.hadoop.conf.Configuration conf, InputStream inputStream) Parse ZooKeeper's zoo.cfg, injecting Dcs Configuration variables in.

Methods inherited from class java.lang.Object

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

Constructor Detail

ZKConfig

public ZKConfig()

Method Detail

makeZKProps

public static Properties makeZKProps(org.apache.hadoop.conf.Configuration conf)

Make a Properties object holding ZooKeeper config equivalent to zoo.cfg. If there is a zoo.cfg in the classpath, simply read it in. Otherwise parse the corresponding config options from the Dcs XML configs and generate the appropriate ZooKeeper properties.

Parameters:

conf - Configuration to read from.

Returns:

Properties holding mappings representing ZooKeeper zoo.cfg file.

parseZooCfg

public static Properties parseZooCfg(org.apache.hadoop.conf.Configuration conf,
                     InputStream inputStream)
                              throws IOException

Parse ZooKeeper's zoo.cfg, injecting Dcs Configuration variables in. This method is used for testing so we can pass our own InputStream.

Parameters:

conf - DcsConfiguration to use for injecting variables.

inputStream - InputStream to read from.

Returns:

Properties parsed from config stream with variables substituted.

Throws:

IOException - if anything goes wrong parsing config

getZKQuorumServersString

public static String getZKQuorumServersString(Properties properties)

Return the ZK Quorum servers string given zk properties returned by makeZKProps

Parameters:

properties -

Returns:

Quorum servers String

getZKQuorumServersString

public static String getZKQuorumServersString(org.apache.hadoop.conf.Configuration conf)

Return the ZK Quorum servers string given the specified configuration.

Parameters:

conf -

Returns:

Quorum servers