Package | Description |
---|---|
org.apache.oozie | |
org.apache.oozie.command.wf | |
org.apache.oozie.executor.jpa | |
org.apache.oozie.service | |
org.apache.oozie.store | |
org.apache.oozie.util |
Modifier and Type | Method and Description |
---|---|
static WorkflowActionBean |
DagELFunctions.getAction() |
WorkflowActionBean |
CoordinatorWfActionBean.getAction() |
WorkflowActionBean |
DagEngine.getWorkflowAction(String actionId) |
Modifier and Type | Method and Description |
---|---|
static void |
DagELFunctions.configureEvaluator(ELEvaluator evaluator,
WorkflowJobBean workflow,
WorkflowActionBean action) |
void |
CoordinatorWfActionBean.setAction(WorkflowActionBean action) |
Modifier and Type | Method and Description |
---|---|
void |
WorkflowJobBean.setActions(List<WorkflowActionBean> nodes) |
static org.json.simple.JSONArray |
WorkflowActionBean.toJSONArray(List<WorkflowActionBean> nodes,
String timeZoneId)
Convert a nodes list into a JSONArray.
|
Constructor and Description |
---|
CoordinatorWfActionBean(int actionNumber,
WorkflowActionBean action,
String nullReason) |
Modifier and Type | Field and Description |
---|---|
protected WorkflowActionBean |
ActionXCommand.ActionExecutorContext.action |
protected WorkflowActionBean |
WorkflowActionRetryInfoXCommand.wfAction |
protected WorkflowActionBean |
ActionStartXCommand.wfAction |
Modifier and Type | Method and Description |
---|---|
protected WorkflowActionBean |
WorkflowActionInfoXCommand.execute() |
Modifier and Type | Method and Description |
---|---|
void |
ForkedActionStartXCommand.failJob(ActionExecutor.Context context,
WorkflowActionBean action) |
void |
ActionXCommand.failJob(ActionExecutor.Context context,
WorkflowActionBean action)
Fail the job due to failed action
|
protected void |
WorkflowXCommand.generateEvent(WorkflowActionBean wfAction,
String wfUser) |
protected void |
ForkedActionStartXCommand.handleError(ActionXCommand.ActionExecutorContext context,
WorkflowJobBean workflow,
WorkflowActionBean action) |
protected void |
ActionStartXCommand.handleError(ActionXCommand.ActionExecutorContext context,
WorkflowJobBean workflow,
WorkflowActionBean action) |
boolean |
ActionXCommand.handleUserRetry(ActionExecutor.Context context,
WorkflowActionBean action)
Execute retry for action if this action is eligible for user-retry
|
Modifier and Type | Method and Description |
---|---|
void |
SignalXCommand.startForkedActions(List<WorkflowActionBean> workflowActionBeanListForForked) |
void |
SignalXCommand.startForkedActionsByQueuing(List<WorkflowActionBean> workflowActionBeanListForForked) |
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
|
ForkedActionExecutorContext(WorkflowJobBean workflow,
WorkflowActionBean action,
boolean isRetry,
boolean isUserRetry) |
WorkflowNotificationXCommand(WorkflowJobBean workflow,
WorkflowActionBean action) |
Modifier and Type | Method and Description |
---|---|
WorkflowActionBean |
WorkflowActionGetJPAExecutor.execute(javax.persistence.EntityManager em) |
WorkflowActionBean |
WorkflowActionQueryExecutor.get(WorkflowActionQueryExecutor.WorkflowActionQuery namedQuery,
Object... parameters) |
WorkflowActionBean |
WorkflowActionQueryExecutor.getIfExist(WorkflowActionQueryExecutor.WorkflowActionQuery namedQuery,
Object... parameters) |
Modifier and Type | Method and Description |
---|---|
List<WorkflowActionBean> |
WorkflowJobGetActionsJPAExecutor.execute(javax.persistence.EntityManager em) |
List<WorkflowActionBean> |
WorkflowActionSubsetGetJPAExecutor.execute(javax.persistence.EntityManager em) |
List<WorkflowActionBean> |
WorkflowActionsGetForJobJPAExecutor.execute(javax.persistence.EntityManager em) |
List<WorkflowActionBean> |
WorkflowActionRetryManualGetJPAExecutor.execute(javax.persistence.EntityManager em) |
static QueryExecutor<WorkflowActionBean,WorkflowActionQueryExecutor.WorkflowActionQuery> |
WorkflowActionQueryExecutor.getInstance() |
List<WorkflowActionBean> |
WorkflowActionQueryExecutor.getList(WorkflowActionQueryExecutor.WorkflowActionQuery namedQuery,
Object... parameters) |
Modifier and Type | Method and Description |
---|---|
int |
WorkflowActionQueryExecutor.executeUpdate(WorkflowActionQueryExecutor.WorkflowActionQuery namedQuery,
WorkflowActionBean actionBean) |
javax.persistence.Query |
WorkflowActionQueryExecutor.getUpdateQuery(WorkflowActionQueryExecutor.WorkflowActionQuery namedQuery,
WorkflowActionBean actionBean,
javax.persistence.EntityManager em) |
Constructor and Description |
---|
WorkflowActionInsertJPAExecutor(WorkflowActionBean wfAction) |
Modifier and Type | Method and Description |
---|---|
static List<WorkflowActionBean> |
WorkflowStoreService.getActionsToStart(WorkflowInstance instance)
Return the list of actions started by a signal in an instance.
|
Modifier and Type | Method and Description |
---|---|
WorkflowActionBean |
WorkflowStore.getAction(String id,
boolean locking)
Load the action data and returns a bean.
|
Modifier and Type | Method and Description |
---|---|
List<WorkflowActionBean> |
WorkflowStore.getActionsForWorkflow(String wfId,
boolean locking)
Loads all the actions for the given Workflow.
|
List<WorkflowActionBean> |
WorkflowStore.getActionsSubsetForWorkflow(String wfId,
int start,
int len)
Loads given number of actions for the given Workflow.
|
List<WorkflowActionBean> |
WorkflowStore.getPendingActions(long minimumPendingAgeSecs)
Load All the actions that are pending for more than given time.
|
List<WorkflowActionBean> |
WorkflowStore.getRetryAndManualActions(String wfId)
Load All the actions that are START_RETRY or START_MANUAL or END_RETRY or END_MANUAL.
|
List<WorkflowActionBean> |
WorkflowStore.getRunningActions(long checkAgeSecs)
Load All the actions that are running and were last checked after now - miminumCheckAgeSecs
|
Modifier and Type | Method and Description |
---|---|
void |
WorkflowStore.insertAction(WorkflowActionBean action)
Create a new Action record in the ACTIONS table with the given Bean.
|
void |
WorkflowStore.updateAction(WorkflowActionBean action)
Update the given action bean to DB.
|
Modifier and Type | Method and Description |
---|---|
static String |
JobUtils.getRetryKey(WorkflowActionBean wfAction,
String key) |
static void |
LogUtils.setLogInfo(WorkflowActionBean action)
Set the thread local log info with the context of the given action bean.
|
Copyright © 2018 Apache Software Foundation. All rights reserved.