org.apache.oozie.service
Class LiteWorkflowStoreService

java.lang.Object
  org.apache.oozie.service.WorkflowStoreService
      org.apache.oozie.service.LiteWorkflowStoreService

All Implemented Interfaces:

Service

Direct Known Subclasses:

DBLiteWorkflowStoreService

public abstract class LiteWorkflowStoreService
extends WorkflowStoreService

Nested Class Summary

static class	LiteWorkflowStoreService.LiteActionHandler
static class	LiteWorkflowStoreService.LiteControlNodeHandler
static class	LiteWorkflowStoreService.LiteDecisionHandler

Field Summary

static String	CONF_NODE_DEF_VERSION
static String	CONF_PREFIX
static String	CONF_PREFIX_USER_RETRY
static String	CONF_USER_RETRY_ERROR_CODE
static String	CONF_USER_RETRY_ERROR_CODE_EXT
static String	CONF_USER_RETRY_INTEVAL
static String	CONF_USER_RETRY_MAX
static String	NODE_DEF_VERSION_0
static String	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

LiteWorkflowStoreService()

Method Summary

static String	getNodeDefDefaultVersion() Get NodeDef default version, _oozie_inst_v_0 or _oozie_inst_v_1
static Set<String>	getUserRetryErrorCode() Get system defined and instance defined error codes for which USER_RETRY is allowed
protected static void	liteExecute(NodeHandler.Context context, String actionType) Delegation method used by the Action and Decision NodeHandler on start.
protected static void	liteFail(NodeHandler.Context context) Delegation method used when failing actions.
protected static void	liteKill(NodeHandler.Context context) Delegation method used when killing actions.

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

create, create, getActionsToFail, getActionsToKill, getInterface, getStartedActions, getWorkflowLibWithNoDB

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

CONF_PREFIX

public static final String CONF_PREFIX

See Also:

Constant Field Values

CONF_PREFIX_USER_RETRY

public static final String CONF_PREFIX_USER_RETRY

See Also:

Constant Field Values

CONF_USER_RETRY_MAX

public static final String CONF_USER_RETRY_MAX

See Also:

Constant Field Values

CONF_USER_RETRY_INTEVAL

public static final String CONF_USER_RETRY_INTEVAL

See Also:

Constant Field Values

CONF_USER_RETRY_ERROR_CODE

public static final String CONF_USER_RETRY_ERROR_CODE

See Also:

Constant Field Values

CONF_USER_RETRY_ERROR_CODE_EXT

public static final String CONF_USER_RETRY_ERROR_CODE_EXT

See Also:

Constant Field Values

NODE_DEF_VERSION_0

public static final String NODE_DEF_VERSION_0

See Also:

Constant Field Values

NODE_DEF_VERSION_1

public static final String NODE_DEF_VERSION_1

See Also:

Constant Field Values

CONF_NODE_DEF_VERSION

public static final String CONF_NODE_DEF_VERSION

See Also:

Constant Field Values

Constructor Detail

LiteWorkflowStoreService

public LiteWorkflowStoreService()

Method Detail

liteExecute

protected static void liteExecute(NodeHandler.Context context,
                                  String actionType)
                           throws WorkflowException

Delegation method used by the Action and Decision NodeHandler on start.

This method provides the necessary information to create ActionExecutors.

Parameters:

context - NodeHandler context.

actionType - the action type.

Throws:

WorkflowException - thrown if there was an error parsing the action configuration.

getUserRetryErrorCode

public static Set<String> getUserRetryErrorCode()

Get system defined and instance defined error codes for which USER_RETRY is allowed

Returns:

set of error code user-retry is allowed for

getNodeDefDefaultVersion

public static String getNodeDefDefaultVersion()
                                       throws WorkflowException

Get NodeDef default version, _oozie_inst_v_0 or _oozie_inst_v_1

Returns:

nodedef default version

Throws:

WorkflowException - thrown if there was an error parsing the action configuration.

liteFail

protected static void liteFail(NodeHandler.Context context)

Delegation method used when failing actions.

Parameters:

context - NodeHandler context.

liteKill

protected static void liteKill(NodeHandler.Context context)

Delegation method used when killing actions.

Parameters:

context - NodeHandler context.