org.apache.flume.node
Class AbstractZooKeeperConfigurationProvider

java.lang.Object
  org.apache.flume.node.AbstractConfigurationProvider
      org.apache.flume.node.AbstractZooKeeperConfigurationProvider

All Implemented Interfaces:

ConfigurationProvider

Direct Known Subclasses:

PollingZooKeeperConfigurationProvider, StaticZooKeeperConfigurationProvider

public abstract class AbstractZooKeeperConfigurationProvider
extends AbstractConfigurationProvider

ZooKeeper based configuration implementation provider. The Agent configuration can be uploaded in ZooKeeper under a base name, which defaults to /flume Currently the agent configuration is stored under the agent name node in ZooKeeper

   /flume
       /a1 [agent config file]
       /a2 [agent config file]
       /a3 [agent config file]
 

Configuration format is same as PropertiesFileConfigurationProvider Configuration properties agentName - Name of Agent for which configuration needs to be pulled zkConnString - Connection string to ZooKeeper Ensemble (host:port,host1:port1) basePath - Base Path where agent configuration needs to be stored. Defaults to /flume

Field Summary

protected String	basePath
protected String	zkConnString

Constructor Summary

protected

AbstractZooKeeperConfigurationProvider(String agentName, String zkConnString, String basePath)

Method Summary

protected FlumeConfiguration	configFromBytes(byte[] configData)
protected org.apache.curator.framework.CuratorFramework	createClient()

Methods inherited from class org.apache.flume.node.AbstractConfigurationProvider

getAgentName, getConfiguration, getFlumeConfiguration, toMap

Methods inherited from class java.lang.Object

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

Field Detail

basePath

protected final String basePath

zkConnString

protected final String zkConnString

Constructor Detail

AbstractZooKeeperConfigurationProvider

protected AbstractZooKeeperConfigurationProvider(String agentName,
                                                 String zkConnString,
                                                 String basePath)

Method Detail

createClient

protected org.apache.curator.framework.CuratorFramework createClient()

configFromBytes

protected FlumeConfiguration configFromBytes(byte[] configData)
                                      throws IOException

Throws:

IOException