| Package | Description |
|---|---|
| org.apache.oozie.command.wf | |
| org.apache.oozie.service | |
| org.apache.oozie.workflow | |
| org.apache.oozie.workflow.lite |
| Modifier and Type | Method and Description |
|---|---|
static void |
SuspendXCommand.suspendJob(JPAService jpaService,
WorkflowJobBean workflow,
java.lang.String id,
java.lang.String actionId,
java.util.List<BatchQueryExecutor.UpdateEntry> updateList)
Suspend the workflow job and pending flag to false for the actions that are START_RETRY or START_MANUAL or
END_RETRY or END_MANUAL
|
| Modifier and Type | Method and Description |
|---|---|
XConfiguration |
WorkflowAppService.createProtoActionConf(org.apache.hadoop.conf.Configuration jobConf,
boolean isWorkflowJob)
Create proto configuration.
|
static java.lang.String |
LiteWorkflowStoreService.getNodeDefDefaultVersion()
Get NodeDef default version, _oozie_inst_v_0 or _oozie_inst_v_1
|
protected static void |
LiteWorkflowStoreService.liteExecute(NodeHandler.Context context,
java.lang.String actionType)
Delegation method used by the Action and Decision
NodeHandler on start. |
abstract WorkflowApp |
WorkflowAppService.parseDef(org.apache.hadoop.conf.Configuration jobConf)
Parse workflow definition.
|
WorkflowApp |
LiteWorkflowAppService.parseDef(org.apache.hadoop.conf.Configuration jobConf)
Parse workflow definition.
|
abstract WorkflowApp |
WorkflowAppService.parseDef(org.apache.hadoop.conf.Configuration jobConf,
org.apache.hadoop.conf.Configuration configDefault)
Parse workflow definition along with config-default.xml config
|
WorkflowApp |
LiteWorkflowAppService.parseDef(org.apache.hadoop.conf.Configuration jobConf,
org.apache.hadoop.conf.Configuration configDefault) |
abstract WorkflowApp |
WorkflowAppService.parseDef(java.lang.String wfXml,
org.apache.hadoop.conf.Configuration jobConf)
Parse workflow definition.
|
WorkflowApp |
LiteWorkflowAppService.parseDef(java.lang.String wfXml,
org.apache.hadoop.conf.Configuration jobConf) |
WorkflowApp |
LiteWorkflowAppService.parseDef(java.lang.String workflowXml,
org.apache.hadoop.conf.Configuration jobConf,
org.apache.hadoop.conf.Configuration configDefault) |
protected java.lang.String |
WorkflowAppService.readDefinition(java.lang.String appPath,
java.lang.String user,
org.apache.hadoop.conf.Configuration conf)
Read workflow definition.
|
void |
LiteWorkflowStoreService.LiteActionHandler.start(NodeHandler.Context context) |
void |
LiteWorkflowStoreService.LiteDecisionHandler.start(NodeHandler.Context context) |
void |
LiteWorkflowStoreService.LiteControlNodeHandler.touch(NodeHandler.Context context) |
| Modifier and Type | Method and Description |
|---|---|
void |
WorkflowLib.close()
Close store.
|
void |
WorkflowLib.commit()
Commit changes to store.
|
WorkflowInstance |
WorkflowLib.createInstance(WorkflowApp app,
org.apache.hadoop.conf.Configuration conf)
Create a workflow instance.
|
WorkflowInstance |
WorkflowLib.createInstance(WorkflowApp app,
org.apache.hadoop.conf.Configuration conf,
java.lang.String wfId)
Create a workflow instance with the given wfId and actions endtime map.
|
void |
WorkflowLib.delete(java.lang.String id)
Delete a workflow instance from storage.
|
void |
WorkflowInstance.fail(java.lang.String nodeName)
Fail the instance.
|
WorkflowInstance |
WorkflowLib.get(java.lang.String id)
Load a workflow instance from storage.
|
void |
WorkflowLib.insert(WorkflowInstance instance)
Insert a workflow instance in storage.
|
void |
WorkflowInstance.kill()
Kill the instance.
|
WorkflowApp |
WorkflowLib.parseDef(java.lang.String wfXml,
org.apache.hadoop.conf.Configuration jobConf,
org.apache.hadoop.conf.Configuration configDefault)
Parse a workflow application definition.
|
void |
WorkflowInstance.resume()
Resume the instance.
|
boolean |
WorkflowInstance.signal(java.lang.String path,
java.lang.String signaValue)
Signal the instance that a node has completed.
|
boolean |
WorkflowInstance.start()
Start the instance.
|
void |
WorkflowInstance.suspend()
Suspend the instance.
|
void |
WorkflowLib.update(WorkflowInstance instance)
Update a workflow instance in storage.
|
| Modifier and Type | Method and Description |
|---|---|
LiteWorkflowApp |
LiteWorkflowApp.addNode(NodeDef node) |
void |
DBLiteWorkflowLib.close() |
void |
DBLiteWorkflowLib.commit() |
WorkflowInstance |
LiteWorkflowLib.createInstance(WorkflowApp app,
org.apache.hadoop.conf.Configuration conf) |
WorkflowInstance |
LiteWorkflowLib.createInstance(WorkflowApp app,
org.apache.hadoop.conf.Configuration conf,
java.lang.String wfId) |
void |
DBLiteWorkflowLib.delete(java.lang.String id)
Delets the Workflow Instance with the given id.
|
abstract void |
DecisionNodeHandler.end(NodeHandler.Context context) |
abstract void |
ActionNodeHandler.end(NodeHandler.Context context) |
boolean |
DecisionNodeHandler.enter(NodeHandler.Context context) |
boolean |
JoinNodeDef.JoinNodeHandler.enter(NodeHandler.Context context) |
boolean |
ActionNodeHandler.enter(NodeHandler.Context context) |
boolean |
StartNodeDef.StartNodeHandler.enter(NodeHandler.Context context) |
abstract boolean |
NodeHandler.enter(NodeHandler.Context context) |
boolean |
ControlNodeHandler.enter(NodeHandler.Context context) |
java.lang.String |
DecisionNodeHandler.exit(NodeHandler.Context context) |
java.lang.String |
ActionNodeHandler.exit(NodeHandler.Context context) |
abstract java.lang.String |
NodeHandler.exit(NodeHandler.Context context) |
java.lang.String |
ControlNodeHandler.exit(NodeHandler.Context context) |
void |
LiteWorkflowInstance.fail(java.lang.String nodeName) |
WorkflowInstance |
DBLiteWorkflowLib.get(java.lang.String id)
Loads the Workflow instance with the given ID.
|
void |
DBLiteWorkflowLib.insert(WorkflowInstance instance)
Save the Workflow Instance for the given Workflow Application.
|
void |
LiteWorkflowInstance.kill() |
void |
JoinNodeDef.JoinNodeHandler.loopDetection(NodeHandler.Context context) |
void |
NodeHandler.loopDetection(NodeHandler.Context context) |
void |
ControlNodeHandler.loopDetection(NodeHandler.Context context) |
java.util.List<java.lang.String> |
NodeHandler.multiExit(NodeHandler.Context context) |
java.util.List<java.lang.String> |
ControlNodeHandler.multiExit(NodeHandler.Context context) |
WorkflowApp |
LiteWorkflowLib.parseDef(java.lang.String appXml,
org.apache.hadoop.conf.Configuration jobConf,
org.apache.hadoop.conf.Configuration configDefault) |
void |
LiteWorkflowInstance.resume() |
boolean |
LiteWorkflowInstance.signal(java.lang.String executionPath,
java.lang.String signalValue) |
boolean |
LiteWorkflowInstance.start() |
abstract void |
DecisionNodeHandler.start(NodeHandler.Context context) |
abstract void |
ActionNodeHandler.start(NodeHandler.Context context) |
void |
LiteWorkflowInstance.suspend() |
abstract void |
ControlNodeHandler.touch(NodeHandler.Context context)
Called by
NodeHandler.enter(Context) when returning TRUE. |
void |
DBLiteWorkflowLib.update(WorkflowInstance instance)
Updates the Workflow Instance to DB.
|
LiteWorkflowApp |
LiteWorkflowAppParser.validateAndParse(java.io.Reader reader,
org.apache.hadoop.conf.Configuration jobConf) |
LiteWorkflowApp |
LiteWorkflowAppParser.validateAndParse(java.io.Reader reader,
org.apache.hadoop.conf.Configuration jobConf,
org.apache.hadoop.conf.Configuration configDefault)
Parse and validate xml to
LiteWorkflowApp |
| Constructor and Description |
|---|
LiteWorkflowAppParser(javax.xml.validation.Schema schema,
java.lang.Class<? extends ControlNodeHandler> controlNodeHandler,
java.lang.Class<? extends DecisionNodeHandler> decisionHandlerClass,
java.lang.Class<? extends ActionNodeHandler> actionHandlerClass) |
Copyright © 2018 Apache Software Foundation. All Rights Reserved.