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

Nested Classes

Modifier and Type	Class and Description
static class	LiteWorkflowStoreService.LiteActionHandler
static class	LiteWorkflowStoreService.LiteControlNodeHandler
static class	LiteWorkflowStoreService.LiteDecisionHandler

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CONF_NODE_DEF_VERSION
static java.lang.String	CONF_PREFIX
static java.lang.String	CONF_PREFIX_USER_RETRY
static java.lang.String	CONF_USER_RETRY_ERROR_CODE
static java.lang.String	CONF_USER_RETRY_ERROR_CODE_EXT
static java.lang.String	CONF_USER_RETRY_INTEVAL
static java.lang.String	CONF_USER_RETRY_MAX
static java.lang.String	NODE_DEF_VERSION_0
static java.lang.String	NODE_DEF_VERSION_1
static java.lang.String	USER_ERROR_CODE_ALL

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

Constructor Summary

Constructors

Constructor and Description
LiteWorkflowStoreService()

Method Summary

Methods

Modifier and Type	Method and Description
static java.lang.String	getNodeDefDefaultVersion() Get NodeDef default version, _oozie_inst_v_0 or _oozie_inst_v_1
static java.util.Set<java.lang.String>	getUserRetryErrorCode() Get system defined and instance defined error codes for which USER_RETRY is allowed
protected static void	liteExecute(NodeHandler.Context context, java.lang.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, getActionsToStart, getInterface, 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 java.lang.String CONF_PREFIX

See Also:

Constant Field Values

CONF_PREFIX_USER_RETRY

public static final java.lang.String CONF_PREFIX_USER_RETRY

See Also:

Constant Field Values

CONF_USER_RETRY_MAX

public static final java.lang.String CONF_USER_RETRY_MAX

See Also:

Constant Field Values

CONF_USER_RETRY_INTEVAL

public static final java.lang.String CONF_USER_RETRY_INTEVAL

See Also:

Constant Field Values

CONF_USER_RETRY_ERROR_CODE

public static final java.lang.String CONF_USER_RETRY_ERROR_CODE

See Also:

Constant Field Values

CONF_USER_RETRY_ERROR_CODE_EXT

public static final java.lang.String CONF_USER_RETRY_ERROR_CODE_EXT

See Also:

Constant Field Values

NODE_DEF_VERSION_0

public static final java.lang.String NODE_DEF_VERSION_0

See Also:

Constant Field Values

NODE_DEF_VERSION_1

public static final java.lang.String NODE_DEF_VERSION_1

See Also:

Constant Field Values

CONF_NODE_DEF_VERSION

public static final java.lang.String CONF_NODE_DEF_VERSION

See Also:

Constant Field Values

USER_ERROR_CODE_ALL

public static final java.lang.String USER_ERROR_CODE_ALL

See Also:

Constant Field Values

Constructor Detail

LiteWorkflowStoreService

public LiteWorkflowStoreService()

Method Detail

liteExecute

protected static void liteExecute(NodeHandler.Context context,
               java.lang.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 java.util.Set<java.lang.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 java.lang.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.