org.apache.oozie.service

Class ShareLibService

java.lang.Object

org.apache.oozie.service.ShareLibService

All Implemented Interfaces:

Service, Instrumentable

public class ShareLibService
extends Object
implements Service, Instrumentable

Field Summary

Fields

Modifier and Type	Field and Description
static SimpleDateFormat	dateFormat
static String	FAIL_FAST_ON_STARTUP
static String	LAUNCHER_LIB_PREFIX
static String	LAUNCHERJAR_LIB_RETENTION
static String	PURGE_INTERVAL
static String	SHARE_LIB_CONF_PREFIX
static String	SHARE_LIB_PREFIX
static String	SHARELIB_MAPPING_FILE
static 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

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

See Also:

Constant Field Values

SHARELIB_MAPPING_FILE

public static final String SHARELIB_MAPPING_FILE

See Also:

Constant Field Values

SHIP_LAUNCHER_JAR

public static final String SHIP_LAUNCHER_JAR

See Also:

Constant Field Values

PURGE_INTERVAL

public static final String PURGE_INTERVAL

See Also:

Constant Field Values

FAIL_FAST_ON_STARTUP

public static final String FAIL_FAST_ON_STARTUP

See Also:

Constant Field Values

LAUNCHER_LIB_PREFIX

public static final String LAUNCHER_LIB_PREFIX

See Also:

Constant Field Values

SHARE_LIB_PREFIX

public static final String SHARE_LIB_PREFIX

See Also:

Constant Field Values

dateFormat

public static final SimpleDateFormat dateFormat

SHARE_LIB_CONF_PREFIX

public static 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 Map<String,List<org.apache.hadoop.fs.Path>> getShareLib()

getShareLibJars

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

Gets the action sharelib lib jars.

Parameters:

shareLibKey - the sharelib key

Returns:

List of paths

Throws:

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

getSystemLibJars

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

Gets the launcher jars.

Parameters:

shareLibKey - the shareLib key

Returns:

launcher jars paths

Throws:

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

findContainingJar

protected String findContainingJar(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 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 Map<String,String> updateShareLib()
                                  throws IOException

Update share lib cache.

Returns:

the map

Throws:

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

getLatestLibPath

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

Gets the Latest lib path.

Parameters:

rootDir - the root dir

prefix - the prefix

Returns:

latest lib path

Throws:

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(String inputKey,
                                                            org.apache.hadoop.fs.Path path)

getShareLibConfigMap

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