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

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

Method Summary

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) Create a workflow instance with the given wfId.
WorkflowApp	parseDef(String appXml, org.apache.hadoop.conf.Configuration jobConf) 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)
                     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

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)
                                throws WorkflowException

Description copied from interface: WorkflowLib

Create a workflow instance with the given wfId. 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.

Returns:

the newly created workflow instance.

Throws:

WorkflowException - thrown if the instance could not be created.