org.apache.oozie.service
Class LiteWorkflowStoreService

java.lang.Object
  extended by org.apache.oozie.service.WorkflowStoreService
      extended by 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.


Copyright © 2013 Apache Software Foundation. All Rights Reserved.