org.apache.oozie.service

Class DBLiteWorkflowStoreService

java.lang.Object

org.apache.oozie.service.WorkflowStoreService

org.apache.oozie.service.LiteWorkflowStoreService

org.apache.oozie.service.DBLiteWorkflowStoreService

All Implemented Interfaces:

Service, Instrumentable

public class DBLiteWorkflowStoreService
extends LiteWorkflowStoreService
implements Instrumentable

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.oozie.service.LiteWorkflowStoreService

LiteWorkflowStoreService.LiteActionHandler, LiteWorkflowStoreService.LiteControlNodeHandler, LiteWorkflowStoreService.LiteDecisionHandler

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONF_METRICS_INTERVAL_MINS
static String	CONF_METRICS_INTERVAL_WINDOW
static String	CONF_PREFIX

Fields inherited from class org.apache.oozie.service.LiteWorkflowStoreService

CONF_NODE_DEF_VERSION, CONF_PREFIX_USER_RETRY, CONF_USER_RETRY_ERROR_CODE, CONF_USER_RETRY_ERROR_CODE_EXT, CONF_USER_RETRY_INTEVAL, CONF_USER_RETRY_MAX, CONF_USER_RETRY_POLICY, DEFAULT_USER_RETRY_POLICY, NODE_DEF_VERSION_0, NODE_DEF_VERSION_1, NODE_DEF_VERSION_2, USER_ERROR_CODE_ALL

Fields inherited from class org.apache.oozie.service.WorkflowStoreService

TRANSIENT_VAR_PREFIX, WORKFLOW_BEAN

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

DEFAULT_LOCK_TIMEOUT, lockTimeout

Constructor Summary

Constructors

Constructor and Description
DBLiteWorkflowStoreService()

Method Summary

Methods

Modifier and Type	Method and Description
WorkflowStore	create() Return a workflow store instance with a fresh transaction.
<S extends Store> WorkflowStore	create(S store) Return a workflow store instance with an existing transaction.
void	destroy() Destroy the service.
WorkflowLib	getWorkflowLibWithNoDB() Return the workflow lib without DB connection.
void	init(Services services) Initialize the service.
void	instrument(Instrumentation instr) Set the system instrumentation.

Methods inherited from class org.apache.oozie.service.LiteWorkflowStoreService

getNodeDefDefaultVersion, getUserRetryErrorCode, liteExecute, liteFail, liteKill

Methods inherited from class org.apache.oozie.service.WorkflowStoreService

getActionsToFail, getActionsToKill, getActionsToStart, getInterface

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 String CONF_PREFIX

See Also:

Constant Field Values

CONF_METRICS_INTERVAL_MINS

public static final String CONF_METRICS_INTERVAL_MINS

See Also:

Constant Field Values

CONF_METRICS_INTERVAL_WINDOW

public static final String CONF_METRICS_INTERVAL_WINDOW

See Also:

Constant Field Values

Constructor Detail

DBLiteWorkflowStoreService

public DBLiteWorkflowStoreService()

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.

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

getWorkflowLibWithNoDB

public WorkflowLib getWorkflowLibWithNoDB()

Return the workflow lib without DB connection. Will be used for parsing purpose.

Specified by:

getWorkflowLibWithNoDB in class WorkflowStoreService

Returns:

Workflow Library

create

public WorkflowStore create()
                     throws StoreException

Description copied from class: WorkflowStoreService

Return a workflow store instance with a fresh transaction.

The workflow store has to be committed and then closed to commit changes, if only close it rolls back.

Specified by:

create in class WorkflowStoreService

Returns:

a workflow store.

Throws:

StoreException - thrown if the workflow store could not be created.

create

public <S extends Store> WorkflowStore create(S store)
                     throws StoreException

Description copied from class: WorkflowStoreService

Return a workflow store instance with an existing transaction.

The workflow store has to be committed and then closed to commit changes, if only close it rolls back.

Overrides:

create in class WorkflowStoreService

Returns:

a workflow store.

Throws:

StoreException - thrown if the workflow store could not be created.

instrument

public void instrument(Instrumentation instr)

Description copied from interface: Instrumentable

Set the system instrumentation.

Specified by:

instrument in interface Instrumentable

Parameters:

instr - system instrumentation.