org.apache.oozie.service

Class ShareLibService

java.lang.Object

org.apache.oozie.service.ShareLibService

All Implemented Interfaces:

Service, Instrumentable

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

Field Summary

Fields

Modifier and Type	Field and Description
static java.text.SimpleDateFormat	dateFormat
static java.lang.String	FAIL_FAST_ON_STARTUP
static java.lang.String	LAUNCHER_LIB_PREFIX
static java.lang.String	LAUNCHERJAR_LIB_RETENTION
static java.lang.String	PURGE_INTERVAL
static java.lang.String	SHARE_LIB_CONF_PREFIX
static java.lang.String	SHARE_LIB_PREFIX
static java.lang.String	SHARELIB_MAPPING_FILE
static java.lang.String	SHIP_LAUNCHER_JAR

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

CONF_PREFIX, DEFAULT_LOCK_TIMEOUT, lockTimeout

Constructor Summary

Constructors

Constructor and Description
ShareLibService()

Method Summary

Methods

Modifier and Type	Method and Description
void	destroy() Destroy the service.
protected java.lang.String	findContainingJar(java.lang.Class clazz) Find containing jar containing.
org.apache.hadoop.fs.FileSystem	getFileSystem() Returns file system for shared libraries.
java.lang.Class<? extends Service>	getInterface() Return the public interface of the service.
org.apache.hadoop.fs.Path	getLatestLibPath(org.apache.hadoop.fs.Path rootDir, java.lang.String prefix) Gets the Latest lib path.
java.util.Map<java.lang.String,java.util.List<org.apache.hadoop.fs.Path>>	getShareLib()
org.apache.hadoop.conf.Configuration	getShareLibConf(java.lang.String inputKey, org.apache.hadoop.fs.Path path)
java.util.Map<java.lang.String,java.util.Map<org.apache.hadoop.fs.Path,org.apache.hadoop.conf.Configuration>>	getShareLibConfigMap()
java.util.List<org.apache.hadoop.fs.Path>	getShareLibJars(java.lang.String shareLibKey) Gets the action sharelib lib jars.
java.util.List<org.apache.hadoop.fs.Path>	getSystemLibJars(java.lang.String shareLibKey) Gets the launcher jars.
void	init(Services services) Initialize the service.
void	instrument(Instrumentation instr) Instruments the log service.
java.util.Map<java.lang.String,java.lang.String>	updateShareLib() Update share lib cache.

Methods inherited from class java.lang.Object

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

Field Detail

LAUNCHERJAR_LIB_RETENTION

public static final java.lang.String LAUNCHERJAR_LIB_RETENTION

See Also:

Constant Field Values

SHARELIB_MAPPING_FILE

public static final java.lang.String SHARELIB_MAPPING_FILE

See Also:

Constant Field Values

SHIP_LAUNCHER_JAR

public static final java.lang.String SHIP_LAUNCHER_JAR

See Also:

Constant Field Values

PURGE_INTERVAL

public static final java.lang.String PURGE_INTERVAL

See Also:

Constant Field Values

FAIL_FAST_ON_STARTUP

public static final java.lang.String FAIL_FAST_ON_STARTUP

See Also:

Constant Field Values

LAUNCHER_LIB_PREFIX

public static final java.lang.String LAUNCHER_LIB_PREFIX

See Also:

Constant Field Values

SHARE_LIB_PREFIX

public static final java.lang.String SHARE_LIB_PREFIX

See Also:

Constant Field Values

dateFormat

public static final java.text.SimpleDateFormat dateFormat

SHARE_LIB_CONF_PREFIX

public static java.lang.String SHARE_LIB_CONF_PREFIX

Constructor Detail

ShareLibService

public ShareLibService()

Method Detail

init

public void init(Services services)
          throws ServiceException

Description copied from interface: Service

Initialize the service.

Invoked by the Service singleton at start up time.

Specified by:

init in interface Service

Parameters:

services - services singleton initializing the service.

Throws:

ServiceException - thrown if the service could not initialize.

getShareLib

public java.util.Map<java.lang.String,java.util.List<org.apache.hadoop.fs.Path>> getShareLib()

getShareLibJars

public java.util.List<org.apache.hadoop.fs.Path> getShareLibJars(java.lang.String shareLibKey)
                                                          throws java.io.IOException

Gets the action sharelib lib jars.

Parameters:

shareLibKey - the sharelib key

Returns:

List of paths

Throws:

java.io.IOException - Signals that an I/O exception has occurred.

getSystemLibJars

public java.util.List<org.apache.hadoop.fs.Path> getSystemLibJars(java.lang.String shareLibKey)
                                                           throws java.io.IOException

Gets the launcher jars.

Parameters:

shareLibKey - the shareLib key

Returns:

launcher jars paths

Throws:

java.io.IOException - Signals that an I/O exception has occurred.

findContainingJar

protected java.lang.String findContainingJar(java.lang.Class clazz)

Find containing jar containing.

Parameters:

clazz - the clazz

Returns:

the string

destroy

public void destroy()

Description copied from interface: Service

Destroy the service.

Invoked by the Service singleton at shutdown time.

Specified by:

destroy in interface Service

getInterface

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

Description copied from interface: Service

Return the public interface of the service.

Services are retrieved by its public interface. Specializations of services must return the public interface.

Specified by:

getInterface in interface Service

Returns:

the interface of the service.

updateShareLib

public java.util.Map<java.lang.String,java.lang.String> updateShareLib()
                                                                throws java.io.IOException

Update share lib cache.

Returns:

the map

Throws:

java.io.IOException - Signals that an I/O exception has occurred.

getLatestLibPath

public org.apache.hadoop.fs.Path getLatestLibPath(org.apache.hadoop.fs.Path rootDir,
                                         java.lang.String prefix)
                                           throws java.io.IOException

Gets the Latest lib path.

Parameters:

rootDir - the root dir

prefix - the prefix

Returns:

latest lib path

Throws:

java.io.IOException - Signals that an I/O exception has occurred.

instrument

public void instrument(Instrumentation instr)

Instruments the log service.

It sets instrumentation variables indicating the location of the sharelib and launcherlib

Specified by:

instrument in interface Instrumentable

Parameters:

instr - instrumentation to use.

getFileSystem

public org.apache.hadoop.fs.FileSystem getFileSystem()

Returns file system for shared libraries.

If WorkflowAppService#getSystemLibPath doesn't have authority then a default one assumed

Returns:

file system for shared libraries

getShareLibConf

public org.apache.hadoop.conf.Configuration getShareLibConf(java.lang.String inputKey,
                                                   org.apache.hadoop.fs.Path path)

getShareLibConfigMap

public java.util.Map<java.lang.String,java.util.Map<org.apache.hadoop.fs.Path,org.apache.hadoop.conf.Configuration>> getShareLibConfigMap()