org.apache.oozie.workflow.lite
Class LiteWorkflowLib

java.lang.Object
  extended by 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.


Copyright © 2012 Apache Software Foundation. All Rights Reserved.