org.apache.oozie.service

Class ConfigurationService

java.lang.Object

org.apache.oozie.service.ConfigurationService

All Implemented Interfaces:

Service, Instrumentable

public class ConfigurationService
extends java.lang.Object
implements Service, Instrumentable

Built in service that initializes the services configuration.

The configuration loading sequence is identical to Hadoop configuration loading sequence.

Default values are loaded from the 'oozie-default.xml' file from the classpath, then site configured values are loaded from a site configuration file from the Oozie configuration directory.

The Oozie configuration directory is resolved using the OOZIE_HOME environment variable as ${OOZIE_HOME}/conf. If the OOZIE_HOME environment variable is not defined the initialization of the ConfigurationService fails.

The site configuration is loaded from the oozie-site.xml file in the configuration directory.

The site configuration file name to use can be changed by setting the OOZIE_CONFIG_FILE environment variable to an alternate file name. The alternate file must ber in the Oozie configuration directory.

Configuration properties, prefixed with 'oozie.', passed as system properties overrides default and site values.

The configuration service logs details on how the configuration was loaded as well as what properties were overrode via system properties settings.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CONF_IGNORE_SYS_PROPS
static java.lang.String	CONF_PREFIX
static java.lang.String	CONF_VERIFY_AVAILABLE_PROPS
static java.lang.String	DEFAULT_CONFIG_FILE
static java.lang.String	OOZIE_CONFIG_DIR System property that indicates the configuration directory.
static java.lang.String	OOZIE_CONFIG_FILE System property that indicates the name of the site configuration file to load.
static java.lang.String	OOZIE_DATA_DIR System property that indicates the data directory.
static java.lang.String	SITE_CONFIG_FILE

Fields inherited from interface org.apache.oozie.service.Service

DEFAULT_LOCK_TIMEOUT, lockTimeout

Constructor Summary

Constructors

Constructor and Description
ConfigurationService()

Method Summary

Methods

Modifier and Type	Method and Description
void	destroy() Destroy the configuration service.
static java.lang.String	get(org.apache.hadoop.conf.Configuration conf, java.lang.String name)
static java.lang.String	get(java.lang.String name)
static boolean	getBoolean(org.apache.hadoop.conf.Configuration conf, java.lang.String name)
static boolean	getBoolean(java.lang.String name)
static boolean	getBoolean(java.lang.String name, boolean defaultValue)
static java.lang.Class<?>	getClass(org.apache.hadoop.conf.Configuration conf, java.lang.String name)
static java.lang.Class<?>[]	getClasses(org.apache.hadoop.conf.Configuration conf, java.lang.String name)
static java.lang.Class<?>[]	getClasses(java.lang.String name)
org.apache.hadoop.conf.Configuration	getConf() Return the services configuration.
java.lang.String	getConfigDir() Return Oozie configuration directory.
static java.lang.String	getConfigurationDirectory()
static float	getFloat(java.lang.String name)
static int	getInt(org.apache.hadoop.conf.Configuration conf, java.lang.String name)
static int	getInt(java.lang.String name)
static int	getInt(java.lang.String name, int defaultValue)
java.lang.Class<? extends Service>	getInterface() Return the public interface for configuration service.
static long	getLong(org.apache.hadoop.conf.Configuration conf, java.lang.String name)
static long	getLong(java.lang.String name)
org.apache.hadoop.conf.Configuration	getMaskedConfiguration() Return a configuration with all sensitive values masked.
static java.lang.String	getPassword(org.apache.hadoop.conf.Configuration conf, java.lang.String name)
static java.lang.String	getPassword(org.apache.hadoop.conf.Configuration conf, java.lang.String name, java.lang.String defaultValue)
static java.lang.String	getPassword(java.lang.String name, java.lang.String defaultValue)
static java.lang.String[]	getStrings(org.apache.hadoop.conf.Configuration conf, java.lang.String name)
static java.lang.String[]	getStrings(java.lang.String name)
void	init(Services services) Initialize the log service.
void	instrument(Instrumentation instr) Instruments the configuration service.
static void	set(java.lang.String name, java.lang.String value)
static void	setBoolean(java.lang.String name, boolean value)
void	verifyConfigurationName() Verify the configuration is in oozie-default

Methods inherited from class java.lang.Object

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

Field Detail

CONF_PREFIX

public static final java.lang.String CONF_PREFIX

See Also:

Constant Field Values

CONF_IGNORE_SYS_PROPS

public static final java.lang.String CONF_IGNORE_SYS_PROPS

See Also:

Constant Field Values

CONF_VERIFY_AVAILABLE_PROPS

public static final java.lang.String CONF_VERIFY_AVAILABLE_PROPS

See Also:

Constant Field Values

OOZIE_CONFIG_DIR

public static final java.lang.String OOZIE_CONFIG_DIR

System property that indicates the configuration directory.

See Also:

Constant Field Values

OOZIE_DATA_DIR

public static final java.lang.String OOZIE_DATA_DIR

System property that indicates the data directory.

See Also:

Constant Field Values

OOZIE_CONFIG_FILE

public static final java.lang.String OOZIE_CONFIG_FILE

System property that indicates the name of the site configuration file to load.

See Also:

Constant Field Values

DEFAULT_CONFIG_FILE

public static final java.lang.String DEFAULT_CONFIG_FILE

See Also:

Constant Field Values

SITE_CONFIG_FILE

public static final java.lang.String SITE_CONFIG_FILE

See Also:

Constant Field Values

Constructor Detail

ConfigurationService

public ConfigurationService()

Method Detail

init

public void init(Services services)
          throws ServiceException

Initialize the log service.

Specified by:

init in interface Service

Parameters:

services - services instance.

Throws:

ServiceException - thrown if the log service could not be initialized.

getConfigurationDirectory

public static java.lang.String getConfigurationDirectory()
                                                  throws ServiceException

Throws:

ServiceException

destroy

public void destroy()

Destroy the configuration service.

Specified by:

destroy in interface Service

getInterface

public java.lang.Class<? extends Service> getInterface()

Return the public interface for configuration service.

Specified by:

getInterface in interface Service

Returns:

ConfigurationService.

getConf

public org.apache.hadoop.conf.Configuration getConf()

Return the services configuration.

Returns:

the services configuration.

getConfigDir

public java.lang.String getConfigDir()

Return Oozie configuration directory.

Returns:

Oozie configuration directory.

instrument

public void instrument(Instrumentation instr)

Instruments the configuration service.

It sets instrumentation variables indicating the config dir and config file used.

Specified by:

instrument in interface Instrumentable

Parameters:

instr - instrumentation to use.

getMaskedConfiguration

public org.apache.hadoop.conf.Configuration getMaskedConfiguration()

Return a configuration with all sensitive values masked.

Returns:

masked configuration.

verifyConfigurationName

public void verifyConfigurationName()

Verify the configuration is in oozie-default

set

public static void set(java.lang.String name,
       java.lang.String value)

setBoolean

public static void setBoolean(java.lang.String name,
              boolean value)

get

public static java.lang.String get(java.lang.String name)

get

public static java.lang.String get(org.apache.hadoop.conf.Configuration conf,
                   java.lang.String name)

getStrings

public static java.lang.String[] getStrings(java.lang.String name)

getStrings

public static java.lang.String[] getStrings(org.apache.hadoop.conf.Configuration conf,
                            java.lang.String name)

getBoolean

public static boolean getBoolean(java.lang.String name)

getBoolean

public static boolean getBoolean(org.apache.hadoop.conf.Configuration conf,
                 java.lang.String name)

getBoolean

public static boolean getBoolean(java.lang.String name,
                 boolean defaultValue)

getInt

public static int getInt(java.lang.String name)

getInt

public static int getInt(java.lang.String name,
         int defaultValue)

getInt

public static int getInt(org.apache.hadoop.conf.Configuration conf,
         java.lang.String name)

getFloat

public static float getFloat(java.lang.String name)

getLong

public static long getLong(java.lang.String name)

getLong

public static long getLong(org.apache.hadoop.conf.Configuration conf,
           java.lang.String name)

getClasses

public static java.lang.Class<?>[] getClasses(java.lang.String name)

getClasses

public static java.lang.Class<?>[] getClasses(org.apache.hadoop.conf.Configuration conf,
                              java.lang.String name)

getClass

public static java.lang.Class<?> getClass(org.apache.hadoop.conf.Configuration conf,
                          java.lang.String name)

getPassword

public static java.lang.String getPassword(org.apache.hadoop.conf.Configuration conf,
                           java.lang.String name)

getPassword

public static java.lang.String getPassword(org.apache.hadoop.conf.Configuration conf,
                           java.lang.String name,
                           java.lang.String defaultValue)

getPassword

public static java.lang.String getPassword(java.lang.String name,
                           java.lang.String defaultValue)