Package | Description |
---|---|
org.apache.oozie | |
org.apache.oozie.command.coord | |
org.apache.oozie.command.wf | |
org.apache.oozie.executor.jpa | |
org.apache.oozie.store | |
org.apache.oozie.util |
Modifier and Type | Method and Description |
---|---|
static WorkflowJobBean |
DagELFunctions.getWorkflow() |
Modifier and Type | Method and Description |
---|---|
List<WorkflowJobBean> |
CoordinatorEngine.getReruns(String coordActionId) |
List<WorkflowJobBean> |
WorkflowsInfo.getWorkflows()
Return the workflows being returned.
|
Modifier and Type | Method and Description |
---|---|
static void |
DagELFunctions.configureEvaluator(ELEvaluator evaluator,
WorkflowJobBean workflow,
WorkflowActionBean action) |
Modifier and Type | Method and Description |
---|---|
static org.json.simple.JSONArray |
WorkflowJobBean.toJSONArray(List<WorkflowJobBean> workflows,
String timeZoneId)
Convert a workflows list into a JSONArray.
|
Constructor and Description |
---|
WorkflowsInfo(List<WorkflowJobBean> workflows,
int start,
int len,
int total)
Create a workflows info bean.
|
Constructor and Description |
---|
CoordActionUpdateXCommand(WorkflowJobBean workflow) |
CoordActionUpdateXCommand(WorkflowJobBean workflow,
int maxRetries) |
Modifier and Type | Field and Description |
---|---|
protected WorkflowJobBean |
ActionStartXCommand.wfJob |
protected WorkflowJobBean |
ActionXCommand.ActionExecutorContext.workflow |
Modifier and Type | Method and Description |
---|---|
protected WorkflowJobBean |
JobXCommand.execute() |
Modifier and Type | Method and Description |
---|---|
protected static void |
WorkflowXCommand.generateEvent(WorkflowJobBean wfJob) |
protected static void |
WorkflowXCommand.generateEvent(WorkflowJobBean wfJob,
String errorCode,
String errorMsg) |
protected void |
ForkedActionStartXCommand.handleError(ActionXCommand.ActionExecutorContext context,
WorkflowJobBean workflow,
WorkflowActionBean action) |
protected void |
ActionStartXCommand.handleError(ActionXCommand.ActionExecutorContext context,
WorkflowJobBean workflow,
WorkflowActionBean action) |
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
|
protected void |
WorkflowXCommand.updateParentIfNecessary(WorkflowJobBean wfjob) |
protected void |
WorkflowXCommand.updateParentIfNecessary(WorkflowJobBean wfjob,
int maxRetries) |
protected void |
ForkedActionStartXCommand.updateParentIfNecessary(WorkflowJobBean wfjob,
int maxRetries) |
Constructor and Description |
---|
ActionExecutorContext(WorkflowJobBean workflow,
WorkflowActionBean action) |
ActionExecutorContext(WorkflowJobBean workflow,
WorkflowActionBean action,
boolean isRetry,
boolean isUserRetry)
Constructing the ActionExecutorContext, setting the private members
and constructing the proto configuration
|
ActionStartXCommand(WorkflowJobBean job,
String actionId,
String type) |
ForkedActionExecutorContext(WorkflowJobBean workflow,
WorkflowActionBean action,
boolean isRetry,
boolean isUserRetry) |
ForkedActionStartXCommand(WorkflowJobBean wfJob,
String id,
String type) |
WfEndXCommand(WorkflowJobBean jobBean) |
WorkflowNotificationXCommand(WorkflowJobBean workflow) |
WorkflowNotificationXCommand(WorkflowJobBean workflow,
WorkflowActionBean action) |
Modifier and Type | Method and Description |
---|---|
WorkflowJobBean |
WorkflowJobGetJPAExecutor.execute(javax.persistence.EntityManager em) |
WorkflowJobBean |
WorkflowInfoWithActionsSubsetGetJPAExecutor.execute(javax.persistence.EntityManager em) |
WorkflowJobBean |
WorkflowJobQueryExecutor.get(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery,
Object... parameters) |
WorkflowJobBean |
WorkflowJobQueryExecutor.getIfExist(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery,
Object... parameters) |
Modifier and Type | Method and Description |
---|---|
List<WorkflowJobBean> |
WorkflowJobsBasicInfoFromWorkflowParentIdJPAExecutor.execute(javax.persistence.EntityManager em) |
List<WorkflowJobBean> |
WorkflowJobsBasicInfoFromCoordParentIdJPAExecutor.execute(javax.persistence.EntityManager em) |
static QueryExecutor<WorkflowJobBean,WorkflowJobQueryExecutor.WorkflowJobQuery> |
WorkflowJobQueryExecutor.getInstance() |
List<WorkflowJobBean> |
WorkflowJobQueryExecutor.getList(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery,
Object... parameters) |
Modifier and Type | Method and Description |
---|---|
int |
WorkflowJobQueryExecutor.executeUpdate(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery,
WorkflowJobBean jobBean) |
javax.persistence.Query |
WorkflowJobQueryExecutor.getUpdateQuery(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery,
WorkflowJobBean wfBean,
javax.persistence.EntityManager em) |
Constructor and Description |
---|
WorkflowJobInsertJPAExecutor(WorkflowJobBean wfJob) |
Modifier and Type | Method and Description |
---|---|
WorkflowJobBean |
WorkflowStore.getWorkflow(String id,
boolean locking)
Load the Workflow into a Bean and return it.
|
WorkflowJobBean |
WorkflowStore.getWorkflowInfo(String id)
Load the Workflow and all Action details and return a WorkflowJobBean.
|
WorkflowJobBean |
WorkflowStore.getWorkflowInfoWithActionsSubset(String id,
int start,
int len)
Load the Workflow and subset Actions details and return a WorkflowJobBean.
|
Modifier and Type | Method and Description |
---|---|
void |
WorkflowStore.insertWorkflow(WorkflowJobBean workflow)
Create a Workflow and return a WorkflowJobBean.
|
void |
WorkflowStore.updateWorkflow(WorkflowJobBean wfBean)
Update the data from Workflow Bean to DB along with the workflow instance data.
|
Modifier and Type | Method and Description |
---|---|
static void |
LogUtils.setLogInfo(WorkflowJobBean workflow)
Set the thread local log info with the context of the given workflow bean.
|
Copyright © 2018 Apache Software Foundation. All rights reserved.