org.apache.oozie.service
Class CoordinatorStoreService

java.lang.Object
  extended by 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
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
CoordinatorStoreService()
           
 
Method Summary
 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


Copyright © 2012 Apache Software Foundation. All Rights Reserved.