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,
String id,
String actionId,
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 String |
LiteWorkflowStoreService.getNodeDefDefaultVersion()
Get NodeDef default version, _oozie_inst_v_0 or _oozie_inst_v_1
|
protected static void |
LiteWorkflowStoreService.liteExecute(NodeHandler.Context context,
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(String wfXml,
org.apache.hadoop.conf.Configuration jobConf)
Parse workflow definition.
|
WorkflowApp |
LiteWorkflowAppService.parseDef(String wfXml,
org.apache.hadoop.conf.Configuration jobConf) |
WorkflowApp |
LiteWorkflowAppService.parseDef(String workflowXml,
org.apache.hadoop.conf.Configuration jobConf,
org.apache.hadoop.conf.Configuration configDefault) |
protected String |
WorkflowAppService.readDefinition(String appPath,
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,
String wfId,
Map<String,Date> actionEndTimes)
Create a workflow instance with the given wfId and actions endtime map.
|
void |
WorkflowLib.delete(String id)
Delete a workflow instance from storage.
|
void |
WorkflowInstance.fail(String nodeName)
Fail the instance.
|
WorkflowInstance |
WorkflowLib.get(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(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(String path,
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,
String wfId,
Map<String,Date> actionEndTimes) |
void |
DBLiteWorkflowLib.delete(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 |
StartNodeDef.StartNodeHandler.enter(NodeHandler.Context context) |
abstract boolean |
NodeHandler.enter(NodeHandler.Context context) |
boolean |
JoinNodeDef.JoinNodeHandler.enter(NodeHandler.Context context) |
boolean |
DecisionNodeHandler.enter(NodeHandler.Context context) |
boolean |
ControlNodeHandler.enter(NodeHandler.Context context) |
boolean |
ActionNodeHandler.enter(NodeHandler.Context context) |
abstract String |
NodeHandler.exit(NodeHandler.Context context) |
String |
DecisionNodeHandler.exit(NodeHandler.Context context) |
String |
ControlNodeHandler.exit(NodeHandler.Context context) |
String |
ActionNodeHandler.exit(NodeHandler.Context context) |
void |
LiteWorkflowInstance.fail(String nodeName) |
WorkflowInstance |
DBLiteWorkflowLib.get(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 |
NodeHandler.loopDetection(NodeHandler.Context context) |
void |
JoinNodeDef.JoinNodeHandler.loopDetection(NodeHandler.Context context) |
void |
ControlNodeHandler.loopDetection(NodeHandler.Context context) |
List<String> |
NodeHandler.multiExit(NodeHandler.Context context) |
List<String> |
ControlNodeHandler.multiExit(NodeHandler.Context context) |
WorkflowApp |
LiteWorkflowLib.parseDef(String appXml,
org.apache.hadoop.conf.Configuration jobConf,
org.apache.hadoop.conf.Configuration configDefault) |
void |
LiteWorkflowInstance.resume() |
boolean |
LiteWorkflowInstance.signal(String executionPath,
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(Reader reader,
org.apache.hadoop.conf.Configuration jobConf) |
LiteWorkflowApp |
LiteWorkflowAppParser.validateAndParse(Reader reader,
org.apache.hadoop.conf.Configuration jobConf,
org.apache.hadoop.conf.Configuration configDefault)
Parse and validate xml to
LiteWorkflowApp |
Constructor and Description |
---|
LiteWorkflowAppParser(Schema schema,
Class<? extends ControlNodeHandler> controlNodeHandler,
Class<? extends DecisionNodeHandler> decisionHandlerClass,
Class<? extends ActionNodeHandler> actionHandlerClass) |
Copyright © 2014 Apache Software Foundation. All Rights Reserved.