org.apache.oozie.service
Class DBLiteWorkflowStoreService

java.lang.Object
  extended by org.apache.oozie.service.WorkflowStoreService
      extended by org.apache.oozie.service.LiteWorkflowStoreService
          extended by 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
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, NODE_DEF_VERSION_0, NODE_DEF_VERSION_1
 
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, USE_XCOMMAND
 
Constructor Summary
DBLiteWorkflowStoreService()
           
 
Method Summary
 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, getInterface, getStartedActions
 
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.


Copyright © 2013 Apache Software Foundation. All Rights Reserved.