Package | Description |
---|---|
org.apache.oozie.service | |
org.apache.oozie.store |
Modifier and Type | Method and Description |
---|---|
abstract WorkflowStore |
WorkflowStoreService.create()
Return a workflow store instance with a fresh transaction.
|
SLAStore |
SLAStoreService.create()
Return a SLA store instance with a fresh transaction.
|
WorkflowStore |
DBLiteWorkflowStoreService.create() |
<S extends Store> |
WorkflowStoreService.create(S store)
Return a workflow store instance with an existing transaction.
|
<S extends Store> |
SLAStoreService.create(S store)
Return a SLA store instance with an existing transaction.
|
<S extends Store> |
DBLiteWorkflowStoreService.create(S store) |
<S extends Store> |
StoreService.getStore(Class<S> klass)
Return instance of store.
|
<S extends Store,T extends Store> |
StoreService.getStore(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(String id)
Delete the Action with given id.
|
WorkflowActionBean |
WorkflowStore.getAction(String id,
boolean locking)
Load the action data and returns a bean.
|
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
|
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(String id,
boolean locking)
Load the Workflow into a Bean and return it.
|
int |
WorkflowStore.getWorkflowCountWithStatus(String status)
Get the number of Workflows with the given status.
|
int |
WorkflowStore.getWorkflowCountWithStatusInLastNSeconds(String status,
int secs)
Get the number of Workflows with the given status which was modified in given time limit.
|
String |
WorkflowStore.getWorkflowIdForExternalId(String externalId)
Get the Workflow ID with given external ID which will be assigned for the subworkflows.
|
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.
|
WorkflowsInfo |
WorkflowStore.getWorkflowsInfo(Map<String,List<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(Connection connection,
boolean selectForUpdate) |
WorkflowStore(Connection connection,
Store store,
boolean selectForUpdate) |
WorkflowStore(Store store,
boolean selectForUpdate) |
Copyright © 2015 Apache Software Foundation. All Rights Reserved.