|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use WorkflowException | |
---|---|
org.apache.oozie.command.wf | |
org.apache.oozie.service | |
org.apache.oozie.workflow | |
org.apache.oozie.workflow.lite |
Uses of WorkflowException in org.apache.oozie.command.wf |
---|
Methods in org.apache.oozie.command.wf that throw WorkflowException | |
---|---|
static void |
SuspendXCommand.suspendJob(JPAService jpaService,
WorkflowJobBean workflow,
String id,
String actionId,
List<JsonBean> 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 |
Uses of WorkflowException in org.apache.oozie.service |
---|
Methods in org.apache.oozie.service that throw WorkflowException | |
---|---|
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(String wfXml,
org.apache.hadoop.conf.Configuration jobConf)
Parse workflow definition. |
WorkflowApp |
LiteWorkflowAppService.parseDef(String workflowXml,
org.apache.hadoop.conf.Configuration jobConf)
|
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)
|
Uses of WorkflowException in org.apache.oozie.workflow |
---|
Methods in org.apache.oozie.workflow that throw WorkflowException | |
---|---|
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)
Create a workflow instance with the given wfId. |
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)
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. |
Uses of WorkflowException in org.apache.oozie.workflow.lite |
---|
Methods in org.apache.oozie.workflow.lite that throw WorkflowException | |
---|---|
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)
|
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)
|
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)
Parse and validate xml to LiteWorkflowApp |
Constructors in org.apache.oozie.workflow.lite that throw WorkflowException | |
---|---|
LiteWorkflowAppParser(Schema schema,
Class<? extends ControlNodeHandler> controlNodeHandler,
Class<? extends DecisionNodeHandler> decisionHandlerClass,
Class<? extends ActionNodeHandler> actionHandlerClass)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |