org.apache.oozie.workflow.lite

Class LiteWorkflowLib

java.lang.Object

org.apache.oozie.workflow.lite.LiteWorkflowLib

All Implemented Interfaces:

WorkflowLib

Direct Known Subclasses:

DBLiteWorkflowLib

public abstract class LiteWorkflowLib
extends Object
implements WorkflowLib

Constructor Summary

Constructors

Constructor and Description
LiteWorkflowLib(Schema schema, Class<? extends ControlNodeHandler> controlNodeHandler, Class<? extends DecisionNodeHandler> decisionHandlerClass, Class<? extends ActionNodeHandler> actionHandlerClass)

Method Summary

Methods

Modifier and Type	Method and Description
WorkflowInstance	createInstance(WorkflowApp app, org.apache.hadoop.conf.Configuration conf) Create a workflow instance.
WorkflowInstance	createInstance(WorkflowApp app, org.apache.hadoop.conf.Configuration conf, String wfId, Map<String,Date> actionEndTimes) Create a workflow instance with the given wfId and actions endtime map.
WorkflowApp	parseDef(String appXml, org.apache.hadoop.conf.Configuration jobConf, org.apache.hadoop.conf.Configuration configDefault) Parse a workflow application definition.

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.workflow.WorkflowLib

close, commit, delete, get, insert, update

Constructor Detail

LiteWorkflowLib

public LiteWorkflowLib(Schema schema,
               Class<? extends ControlNodeHandler> controlNodeHandler,
               Class<? extends DecisionNodeHandler> decisionHandlerClass,
               Class<? extends ActionNodeHandler> actionHandlerClass)

Method Detail

parseDef

public WorkflowApp parseDef(String appXml,
                   org.apache.hadoop.conf.Configuration jobConf,
                   org.apache.hadoop.conf.Configuration configDefault)
                     throws WorkflowException

Description copied from interface: WorkflowLib

Parse a workflow application definition.

Specified by:

parseDef in interface WorkflowLib

Parameters:

appXml - string containing the workflow definition.

jobConf - job configuration

configDefault - configuration from config-default.xml

Returns:

the parse workflow application.

Throws:

WorkflowException - thrown if the definition could not be parsed.

createInstance

public WorkflowInstance createInstance(WorkflowApp app,
                              org.apache.hadoop.conf.Configuration conf)
                                throws WorkflowException

Description copied from interface: WorkflowLib

Create a workflow instance.

Specified by:

createInstance in interface WorkflowLib

Parameters:

app - application to create a workflow instance of.

conf - job configuration.

Returns:

the newly created workflow instance.

Throws:

WorkflowException - thrown if the instance could not be created.

createInstance

public WorkflowInstance createInstance(WorkflowApp app,
                              org.apache.hadoop.conf.Configuration conf,
                              String wfId,
                              Map<String,Date> actionEndTimes)
                                throws WorkflowException

Description copied from interface: WorkflowLib

Create a workflow instance with the given wfId and actions endtime map. This will be used for re-running workflows.

Specified by:

createInstance in interface WorkflowLib

Parameters:

app - application to create a workflow instance of.

conf - job configuration.

wfId - Workflow ID.

actionEndTimes - A map of the actions to their endtimes; actions with no endtime should be omitted

Returns:

the newly created workflow instance.

Throws:

WorkflowException - thrown if the instance could not be created.