org.apache.oozie.service

Class WorkflowStoreService

java.lang.Object

org.apache.oozie.service.WorkflowStoreService

All Implemented Interfaces:

Service

Direct Known Subclasses:

LiteWorkflowStoreService

public abstract class WorkflowStoreService
extends java.lang.Object
implements Service

Base service for persistency of jobs and actions.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	TRANSIENT_VAR_PREFIX
static java.lang.String	WORKFLOW_BEAN

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

CONF_PREFIX, DEFAULT_LOCK_TIMEOUT, lockTimeout

Constructor Summary

Constructors

Constructor and Description
WorkflowStoreService()

Method Summary

Methods

Modifier and Type	Method and Description
abstract 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.
static java.util.List<java.lang.String>	getActionsToFail(WorkflowInstance instance) Return the list of action IDs to fail.
static java.util.List<java.lang.String>	getActionsToKill(WorkflowInstance instance) Return the list of action IDs to kill.
static java.util.List<WorkflowActionBean>	getActionsToStart(WorkflowInstance instance) Return the list of actions started by a signal in an instance.
java.lang.Class<? extends Service>	getInterface() Return the public interface of the service.
abstract WorkflowLib	getWorkflowLibWithNoDB() Return a workkflow lib, giving access to the parser functionality.

Methods inherited from class java.lang.Object

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

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

destroy, init

Field Detail

TRANSIENT_VAR_PREFIX

public static final java.lang.String TRANSIENT_VAR_PREFIX

See Also:

Constant Field Values

WORKFLOW_BEAN

public static final java.lang.String WORKFLOW_BEAN

See Also:

Constant Field Values

Constructor Detail

WorkflowStoreService

public WorkflowStoreService()

Method Detail

getInterface

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

Return the public interface of the service.

Specified by:

getInterface in interface Service

Returns:

WorkflowStoreService.

getWorkflowLibWithNoDB

public abstract WorkflowLib getWorkflowLibWithNoDB()

Return a workkflow lib, giving access to the parser functionality.

Returns:

a workflow lib to use the parser.

create

public abstract WorkflowStore create()
                              throws StoreException

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.

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

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.

Returns:

a workflow store.

Throws:

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

getActionsToStart

public static java.util.List<WorkflowActionBean> getActionsToStart(WorkflowInstance instance)

Return the list of actions started by a signal in an instance.

Parameters:

instance - workflow instance that has been signaled.

Returns:

the list of actions started by the signaling.

getActionsToKill

public static java.util.List<java.lang.String> getActionsToKill(WorkflowInstance instance)

Return the list of action IDs to kill.

Parameters:

instance - workflow instance

Returns:

the list of action IDs to kill.

getActionsToFail

public static java.util.List<java.lang.String> getActionsToFail(WorkflowInstance instance)

Return the list of action IDs to fail.

Parameters:

instance - workflow instance

Returns:

the list of action IDs to fail.