@InterfaceAudience.Private public final class ZKConfig extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
ZKConfig.ZKClusterKey |
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
buildZKQuorumServerString(java.lang.String[] serverHosts,
java.lang.String clientPort)
Build the ZK quorum server string with "server:clientport" list, separated by ','
|
static java.lang.String |
getZKQuorumServersString(Configuration conf)
Return the ZK Quorum servers string given the specified configuration.
|
static java.lang.String |
getZooKeeperClusterKey(Configuration conf)
Get the key to the ZK ensemble for this configuration without
adding a name at the end
|
static java.lang.String |
getZooKeeperClusterKey(Configuration conf,
java.lang.String name)
Get the key to the ZK ensemble for this configuration and append
a name at the end
|
static java.util.Properties |
makeZKProps(Configuration conf)
Make a Properties object holding ZooKeeper config.
|
static java.util.Properties |
parseZooCfg(Configuration conf,
java.io.InputStream inputStream)
Deprecated.
in 0.96 onwards. HBase will no longer rely on zoo.cfg
availability.
|
static java.lang.String |
standardizeZKQuorumServerString(java.lang.String quorumStringInput,
java.lang.String clientPort)
Standardize the ZK quorum string: make it a "server:clientport" list, separated by ','
|
static ZKConfig.ZKClusterKey |
transformClusterKey(java.lang.String key)
Separate the given key into the three configurations it should contain:
hbase.zookeeper.quorum, hbase.zookeeper.client.port
and zookeeper.znode.parent
|
static void |
validateClusterKey(java.lang.String key)
Verifies that the given key matches the expected format for a ZooKeeper cluster key.
|
public static java.util.Properties makeZKProps(Configuration conf)
conf
- Configuration to read from.@Deprecated public static java.util.Properties parseZooCfg(Configuration conf, java.io.InputStream inputStream) throws java.io.IOException
conf
- HBaseConfiguration to use for injecting variables.inputStream
- InputStream to read from.java.io.IOException
- if anything goes wrong parsing configpublic static java.lang.String getZKQuorumServersString(Configuration conf)
conf
- public static java.lang.String buildZKQuorumServerString(java.lang.String[] serverHosts, java.lang.String clientPort)
serverHosts
- a list of servers for ZK quorumclientPort
- the default client portpublic static void validateClusterKey(java.lang.String key) throws java.io.IOException
key
- the cluster key to validatejava.io.IOException
- if the key could not be parsedpublic static ZKConfig.ZKClusterKey transformClusterKey(java.lang.String key) throws java.io.IOException
key
- java.io.IOException
public static java.lang.String getZooKeeperClusterKey(Configuration conf)
conf
- Configuration to use to build the keypublic static java.lang.String getZooKeeperClusterKey(Configuration conf, java.lang.String name)
conf
- Configuration to use to build the keyname
- Name that should be appended at the end if not empty or nullpublic static java.lang.String standardizeZKQuorumServerString(java.lang.String quorumStringInput, java.lang.String clientPort)
quorumStringInput
- a string contains a list of servers for ZK quorumclientPort
- the default client port