org.apache.oozie.service

Class CoordinatorStoreService

java.lang.Object

org.apache.oozie.service.CoordinatorStoreService

All Implemented Interfaces:

Service

public class CoordinatorStoreService
extends Object
implements Service

Base service for persistency of jobs and actions.

Field Summary

Fields

Modifier and Type	Field and Description
static String	TRANSIENT_VAR_PREFIX
static String	WORKFLOW_BEAN

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

CONF_PREFIX, DEFAULT_LOCK_TIMEOUT, lockTimeout, USE_XCOMMAND

Constructor Summary

Constructors

Constructor and Description
CoordinatorStoreService()

Method Summary

Methods

Modifier and Type	Method and Description
CoordinatorStore	create() Return a workflow store instance with a fresh transaction.
<S extends Store> CoordinatorStore	create(S store) Return a workflow store instance with an existing transaction.
void	destroy() Destroy the StoreService
Class<? extends Service>	getInterface() Return the public interface of the service.
void	init(Services services) Initializes the StoreService.

Methods inherited from class java.lang.Object

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

Field Detail

TRANSIENT_VAR_PREFIX

public static final String TRANSIENT_VAR_PREFIX

See Also:

Constant Field Values

WORKFLOW_BEAN

public static final String WORKFLOW_BEAN

See Also:

Constant Field Values

Constructor Detail

CoordinatorStoreService

public CoordinatorStoreService()

Method Detail

getInterface

public Class<? extends Service> getInterface()

Return the public interface of the service.

Specified by:

getInterface in interface Service

Returns:

WorkflowStoreService.

create

public CoordinatorStore create()
                        throws StoreException

Return a workflow store instance with a fresh transaction.

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

Returns:

a coordinator store.

Throws:

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

create

public <S extends Store> CoordinatorStore 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.

init

public void init(Services services)
          throws ServiceException

Initializes the StoreService.

Specified by:

init in interface Service

Parameters:

services - services instance.

Throws:

ServiceException - thrown if the service could not initialize.

destroy

public void destroy()

Destroy the StoreService

Specified by:

destroy in interface Service