org.apache.bookkeeper.conf

Class AbstractConfiguration

java.lang.Object

org.apache.commons.configuration.event.EventSource

org.apache.commons.configuration.AbstractConfiguration

org.apache.commons.configuration.CompositeConfiguration

org.apache.bookkeeper.conf.AbstractConfiguration

All Implemented Interfaces:

Cloneable, org.apache.commons.configuration.Configuration

Direct Known Subclasses:

ClientConfiguration, ServerConfiguration

public abstract class AbstractConfiguration
extends org.apache.commons.configuration.CompositeConfiguration

Abstract configuration

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	AVAILABLE_NODE
protected static ClassLoader	defaultLoader
protected static String	LEDGER_MANAGER_FACTORY_CLASS
protected static String	LEDGER_MANAGER_TYPE
protected static String	METASTORE_IMPL_CLASS
protected static String	METASTORE_MAX_ENTRIES_PER_SCAN
protected static String	REREPLICATION_ENTRY_BATCH_SIZE
protected static String	ZK_LEDGERS_ROOT_PATH

Fields inherited from class org.apache.commons.configuration.AbstractConfiguration

END_TOKEN, EVENT_ADD_PROPERTY, EVENT_CLEAR, EVENT_CLEAR_PROPERTY, EVENT_READ_PROPERTY, EVENT_SET_PROPERTY, START_TOKEN

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractConfiguration()

Method Summary

Modifier and Type	Method and Description
Class<? extends org.apache.bookkeeper.meta.LedgerManagerFactory>	getLedgerManagerFactoryClass() Get ledger manager factory class.
String	getLedgerManagerType() Deprecated. replaced by getLedgerManagerFactoryClass()
String	getMetastoreImplClass() Get metastore implementation class.
int	getMetastoreMaxEntriesPerScan() Get max entries per scan in metastore.
long	getRereplicationEntryBatchSize() Get the re-replication entry batch size
String	getZkAvailableBookiesPath() Get the node under which available bookies are stored
String	getZkLedgersRootPath() Get Zk Ledgers Root Path.
void	loadConf(AbstractConfiguration baseConf) You can load configuration from other configuration
void	loadConf(org.apache.commons.configuration.Configuration otherConf) Load configuration from other configuration object
void	loadConf(URL confURL) You can load configurations in precedence order.
void	setLedgerManagerFactoryClass(Class<? extends org.apache.bookkeeper.meta.LedgerManagerFactory> factoryClass) Set Ledger Manager Factory Class.
void	setLedgerManagerFactoryClassName(String factoryClassName) Set Ledger Manager Factory Class Name.
void	setLedgerManagerType(String lmType) Deprecated. replaced by setLedgerManagerFactoryClass(java.lang.Class<? extends org.apache.bookkeeper.meta.LedgerManagerFactory>)
void	setMetastoreImplClass(String metastoreImplClass) Set metastore implementation class.
void	setMetastoreMaxEntriesPerScan(int maxEntries) Set max entries per scan in metastore.
void	setRereplicationEntryBatchSize(long rereplicationEntryBatchSize) Set the max entries to keep in fragment for re-replication.
void	setZkLedgersRootPath(String zkLedgersPath) Set Zk Ledgers Root Path.

Methods inherited from class org.apache.commons.configuration.CompositeConfiguration

addConfiguration, addPropertyDirect, clear, clearPropertyDirect, clone, containsKey, getConfiguration, getInMemoryConfiguration, getKeys, getKeys, getList, getNumberOfConfigurations, getProperty, getSource, getStringArray, isEmpty, removeConfiguration, setDelimiterParsingDisabled, setListDelimiter

Methods inherited from class org.apache.commons.configuration.AbstractConfiguration

addErrorLogListener, addProperty, append, clearProperty, copy, createInterpolator, getBigDecimal, getBigDecimal, getBigInteger, getBigInteger, getBoolean, getBoolean, getBoolean, getByte, getByte, getByte, getDefaultListDelimiter, getDelimiter, getDouble, getDouble, getDouble, getFloat, getFloat, getFloat, getInt, getInt, getInteger, getInterpolator, getList, getListDelimiter, getLogger, getLong, getLong, getLong, getProperties, getProperties, getShort, getShort, getShort, getString, getString, getSubstitutor, interpolate, interpolate, interpolatedConfiguration, interpolateHelper, isDelimiterParsingDisabled, isThrowExceptionOnMissing, resolveContainerStore, setDefaultListDelimiter, setDelimiter, setLogger, setProperty, setThrowExceptionOnMissing, subset

Methods inherited from class org.apache.commons.configuration.event.EventSource

addConfigurationListener, addErrorListener, clearConfigurationListeners, clearErrorListeners, createErrorEvent, createEvent, fireError, fireEvent, getConfigurationListeners, getErrorListeners, isDetailEvents, removeConfigurationListener, removeErrorListener, setDetailEvents

Methods inherited from class java.lang.Object

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

Field Detail

defaultLoader

protected static final ClassLoader defaultLoader

LEDGER_MANAGER_TYPE

protected static final String LEDGER_MANAGER_TYPE

See Also:

Constant Field Values

LEDGER_MANAGER_FACTORY_CLASS

protected static final String LEDGER_MANAGER_FACTORY_CLASS

See Also:

Constant Field Values

ZK_LEDGERS_ROOT_PATH

protected static final String ZK_LEDGERS_ROOT_PATH

See Also:

Constant Field Values

AVAILABLE_NODE

protected static final String AVAILABLE_NODE

See Also:

Constant Field Values

REREPLICATION_ENTRY_BATCH_SIZE

protected static final String REREPLICATION_ENTRY_BATCH_SIZE

See Also:

Constant Field Values

METASTORE_IMPL_CLASS

protected static final String METASTORE_IMPL_CLASS

See Also:

Constant Field Values

METASTORE_MAX_ENTRIES_PER_SCAN

protected static final String METASTORE_MAX_ENTRIES_PER_SCAN

See Also:

Constant Field Values

Constructor Detail

AbstractConfiguration

protected AbstractConfiguration()

Method Detail

loadConf

public void loadConf(URL confURL)
              throws org.apache.commons.configuration.ConfigurationException

You can load configurations in precedence order. The first one takes precedence over any loaded later.

Parameters:

confURL - Configuration URL

Throws:

org.apache.commons.configuration.ConfigurationException

loadConf

public void loadConf(AbstractConfiguration baseConf)

You can load configuration from other configuration

Parameters:

baseConf - Other Configuration

loadConf

public void loadConf(org.apache.commons.configuration.Configuration otherConf)

Load configuration from other configuration object

Parameters:

otherConf - Other configuration object

setLedgerManagerType

@Deprecated
public void setLedgerManagerType(String lmType)

Deprecated. replaced by setLedgerManagerFactoryClass(java.lang.Class<? extends org.apache.bookkeeper.meta.LedgerManagerFactory>)

Set Ledger Manager Type.

Parameters:

lmType - Ledger Manager Type

getLedgerManagerType

@Deprecated
public String getLedgerManagerType()

Deprecated. replaced by getLedgerManagerFactoryClass()

Get Ledger Manager Type.

Returns:

ledger manager type

Throws:

org.apache.commons.configuration.ConfigurationException

setLedgerManagerFactoryClassName

public void setLedgerManagerFactoryClassName(String factoryClassName)

Set Ledger Manager Factory Class Name.

Parameters:

factoryClassName - Ledger Manager Factory Class Name

setLedgerManagerFactoryClass

public void setLedgerManagerFactoryClass(Class<? extends org.apache.bookkeeper.meta.LedgerManagerFactory> factoryClass)

Set Ledger Manager Factory Class.

Parameters:

factoryClass - Ledger Manager Factory Class

getLedgerManagerFactoryClass

public Class<? extends org.apache.bookkeeper.meta.LedgerManagerFactory> getLedgerManagerFactoryClass()
                                                                                              throws org.apache.commons.configuration.ConfigurationException

Get ledger manager factory class.

Returns:

ledger manager factory class

Throws:

org.apache.commons.configuration.ConfigurationException

setZkLedgersRootPath

public void setZkLedgersRootPath(String zkLedgersPath)

Set Zk Ledgers Root Path.

Parameters:

zkLedgersPath - zk ledgers root path

getZkLedgersRootPath

public String getZkLedgersRootPath()

Get Zk Ledgers Root Path.

Returns:

zk ledgers root path

getZkAvailableBookiesPath

public String getZkAvailableBookiesPath()

Get the node under which available bookies are stored

Returns:

Node under which available bookies are stored.

setRereplicationEntryBatchSize

public void setRereplicationEntryBatchSize(long rereplicationEntryBatchSize)

Set the max entries to keep in fragment for re-replication. If fragment has more entries than this count, then the original fragment will be split into multiple small logical fragments by keeping max entries count to rereplicationEntryBatchSize. So, re-replication will happen in batches wise.

getRereplicationEntryBatchSize

public long getRereplicationEntryBatchSize()

Get the re-replication entry batch size

getMetastoreImplClass

public String getMetastoreImplClass()

Get metastore implementation class.

Returns:

metastore implementation class name.

setMetastoreImplClass

public void setMetastoreImplClass(String metastoreImplClass)

Set metastore implementation class.

Parameters:

metastoreImplClass - Metastore implementation Class name.

getMetastoreMaxEntriesPerScan

public int getMetastoreMaxEntriesPerScan()

Get max entries per scan in metastore.

Returns:

max entries per scan in metastore.

setMetastoreMaxEntriesPerScan

public void setMetastoreMaxEntriesPerScan(int maxEntries)

Set max entries per scan in metastore.

Parameters:

maxEntries - Max entries per scan in metastore.