| Package | Description |
|---|---|
| org.apache.oozie.service | |
| org.apache.oozie.store |
| Modifier and Type | Method and Description |
|---|---|
SLAStore |
SLAStoreService.create()
Return a SLA store instance with a fresh transaction.
|
abstract WorkflowStore |
WorkflowStoreService.create()
Return a workflow store instance with a fresh transaction.
|
WorkflowStore |
DBLiteWorkflowStoreService.create() |
<S extends Store> |
SLAStoreService.create(S store)
Return a SLA store instance with an existing transaction.
|
<S extends Store> |
WorkflowStoreService.create(S store)
Return a workflow store instance with an existing transaction.
|
<S extends Store> |
DBLiteWorkflowStoreService.create(S store) |
<S extends Store> |
StoreService.getStore(java.lang.Class<S> klass)
Return instance of store.
|
<S extends Store,T extends Store> |
StoreService.getStore(java.lang.Class<S> klass,
T store)
Return instance of store with an EntityManager pointing to an existing Store.
|
| Modifier and Type | Method and Description |
|---|---|
void |
WorkflowStore.deleteAction(java.lang.String id)
Delete the Action with given id.
|
WorkflowActionBean |
WorkflowStore.getAction(java.lang.String id,
boolean locking)
Load the action data and returns a bean.
|
java.util.List<WorkflowActionBean> |
WorkflowStore.getActionsForWorkflow(java.lang.String wfId,
boolean locking)
Loads all the actions for the given Workflow.
|
java.util.List<WorkflowActionBean> |
WorkflowStore.getActionsSubsetForWorkflow(java.lang.String wfId,
int start,
int len)
Loads given number of actions for the given Workflow.
|
java.util.List<WorkflowActionBean> |
WorkflowStore.getPendingActions(long minimumPendingAgeSecs)
Load All the actions that are pending for more than given time.
|
java.util.List<WorkflowActionBean> |
WorkflowStore.getRetryAndManualActions(java.lang.String wfId)
Load All the actions that are START_RETRY or START_MANUAL or END_RETRY or END_MANUAL.
|
java.util.List<WorkflowActionBean> |
WorkflowStore.getRunningActions(long checkAgeSecs)
Load All the actions that are running and were last checked after now - miminumCheckAgeSecs
|
java.util.List<SLAEventBean> |
SLAStore.getSLAEventListNewerSeqLimited(long seqId,
int limitLen,
long[] lastSeqId)
Deprecated.
Get a list of SLA Events newer than a specific sequence with limit
clause.
|
WorkflowJobBean |
WorkflowStore.getWorkflow(java.lang.String id,
boolean locking)
Load the Workflow into a Bean and return it.
|
int |
WorkflowStore.getWorkflowCountWithStatus(java.lang.String status)
Get the number of Workflows with the given status.
|
int |
WorkflowStore.getWorkflowCountWithStatusInLastNSeconds(java.lang.String status,
int secs)
Get the number of Workflows with the given status which was modified in given time limit.
|
java.lang.String |
WorkflowStore.getWorkflowIdForExternalId(java.lang.String externalId)
Get the Workflow ID with given external ID which will be assigned for the subworkflows.
|
WorkflowJobBean |
WorkflowStore.getWorkflowInfo(java.lang.String id)
Load the Workflow and all Action details and return a WorkflowJobBean.
|
WorkflowJobBean |
WorkflowStore.getWorkflowInfoWithActionsSubset(java.lang.String id,
int start,
int len)
Load the Workflow and subset Actions details and return a WorkflowJobBean.
|
WorkflowsInfo |
WorkflowStore.getWorkflowsInfo(java.util.Map<java.lang.String,java.util.List<java.lang.String>> filter,
int start,
int len)
Loads all the jobs that are satisfying the given filter condition.
|
void |
WorkflowStore.insertAction(WorkflowActionBean action)
Create a new Action record in the ACTIONS table with the given Bean.
|
void |
SLAStore.insertSLAEvent(SLAEventBean slaEvent)
Deprecated.
Create a CoordJobBean.
|
void |
WorkflowStore.insertWorkflow(WorkflowJobBean workflow)
Create a Workflow and return a WorkflowJobBean.
|
void |
WorkflowStore.purge(long olderThanDays,
int limit)
Purge the Workflows Completed older than given days.
|
void |
WorkflowStore.updateAction(WorkflowActionBean action)
Update the given action bean to DB.
|
void |
WorkflowStore.updateWorkflow(WorkflowJobBean wfBean)
Update the data from Workflow Bean to DB along with the workflow instance data.
|
| Constructor and Description |
|---|
SLAStore()
Deprecated.
|
SLAStore(Store store)
Deprecated.
|
WorkflowStore(boolean selectForUpdate) |
WorkflowStore(java.sql.Connection connection,
boolean selectForUpdate) |
WorkflowStore(java.sql.Connection connection,
Store store,
boolean selectForUpdate) |
WorkflowStore(Store store,
boolean selectForUpdate) |
Copyright © 2017 Apache Software Foundation. All Rights Reserved.