public abstract class LiteWorkflowLib extends Object implements WorkflowLib
Constructor and Description |
---|
LiteWorkflowLib(Schema schema,
Class<? extends ControlNodeHandler> controlNodeHandler,
Class<? extends DecisionNodeHandler> decisionHandlerClass,
Class<? extends ActionNodeHandler> actionHandlerClass) |
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)
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.
|
public LiteWorkflowLib(Schema schema, Class<? extends ControlNodeHandler> controlNodeHandler, Class<? extends DecisionNodeHandler> decisionHandlerClass, Class<? extends ActionNodeHandler> actionHandlerClass)
public WorkflowApp parseDef(String appXml, org.apache.hadoop.conf.Configuration jobConf, org.apache.hadoop.conf.Configuration configDefault) throws WorkflowException
WorkflowLib
parseDef
in interface WorkflowLib
appXml
- string containing the workflow definition.jobConf
- job configurationconfigDefault
- configuration from config-default.xmlWorkflowException
- thrown if the definition could not be parsed.public WorkflowInstance createInstance(WorkflowApp app, org.apache.hadoop.conf.Configuration conf) throws WorkflowException
WorkflowLib
createInstance
in interface WorkflowLib
app
- application to create a workflow instance of.conf
- job configuration.WorkflowException
- thrown if the instance could not be created.public WorkflowInstance createInstance(WorkflowApp app, org.apache.hadoop.conf.Configuration conf, String wfId) throws WorkflowException
WorkflowLib
createInstance
in interface WorkflowLib
app
- application to create a workflow instance of.conf
- job configuration.wfId
- Workflow ID.WorkflowException
- thrown if the instance could not be created.Copyright © 2018 Apache Software Foundation. All rights reserved.