org.apache.oozie.workflow.lite

Class ControlNodeHandler

java.lang.Object

org.apache.oozie.workflow.lite.NodeHandler

org.apache.oozie.workflow.lite.ControlNodeHandler

Direct Known Subclasses:

LiteWorkflowStoreService.LiteControlNodeHandler

public abstract class ControlNodeHandler
extends NodeHandler

Node handler that provides the necessary workflow logic for control nodes: START/END/KILL/FORK/JOIN.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.oozie.workflow.lite.NodeHandler

NodeHandler.Context

Field Summary

Fields

Modifier and Type	Field and Description
static String	FORK_COUNT_PREFIX
XLog	LOG

Constructor Summary

Constructors

Constructor and Description
ControlNodeHandler()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	enter(NodeHandler.Context context)
String	exit(NodeHandler.Context context)
void	fail(NodeHandler.Context context)
void	kill(NodeHandler.Context context)
void	loopDetection(NodeHandler.Context context)
List<String>	multiExit(NodeHandler.Context context)
abstract void	touch(NodeHandler.Context context) Called by NodeHandler.enter(Context) when returning TRUE.

Methods inherited from class org.apache.oozie.workflow.lite.NodeHandler

getLoopFlag

Methods inherited from class java.lang.Object

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

Field Detail

FORK_COUNT_PREFIX

public static final String FORK_COUNT_PREFIX

See Also:

Constant Field Values

LOG

public XLog LOG

Constructor Detail

ControlNodeHandler

public ControlNodeHandler()

Method Detail

touch

public abstract void touch(NodeHandler.Context context)
                    throws WorkflowException

Called by NodeHandler.enter(Context) when returning TRUE.

Parameters:

context - workflow context

Throws:

WorkflowException - thrown if an error occurred.

enter

public boolean enter(NodeHandler.Context context)
              throws WorkflowException

Specified by:

enter in class NodeHandler

Throws:

WorkflowException

exit

public String exit(NodeHandler.Context context)
            throws WorkflowException

Specified by:

exit in class NodeHandler

Throws:

WorkflowException

loopDetection

public void loopDetection(NodeHandler.Context context)
                   throws WorkflowException

Overrides:

loopDetection in class NodeHandler

Throws:

WorkflowException

multiExit

public List<String> multiExit(NodeHandler.Context context)
                       throws WorkflowException

Overrides:

multiExit in class NodeHandler

Throws:

WorkflowException

kill

public void kill(NodeHandler.Context context)

Overrides:

kill in class NodeHandler

fail

public void fail(NodeHandler.Context context)

Overrides:

fail in class NodeHandler