Uses of Class
org.apache.oozie.store.StoreException

Packages that use StoreException
org.apache.oozie.command   
org.apache.oozie.command.coord   
org.apache.oozie.service   
org.apache.oozie.store   
 

Uses of StoreException in org.apache.oozie.command
 

Methods in org.apache.oozie.command that throw StoreException
protected abstract  T Command.call(S store)
          DagCallable subclasses must implement this method to perform their task.
protected  T Command.execute(S store)
           
 

Uses of StoreException in org.apache.oozie.command.coord
 

Methods in org.apache.oozie.command.coord that throw StoreException
protected  Void CoordActionMaterializeCommand.execute(CoordinatorStore store)
           
 

Uses of StoreException in org.apache.oozie.service
 

Methods in org.apache.oozie.service that throw StoreException
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()
           
 CoordinatorStore CoordinatorStoreService.create()
          Return a workflow store instance with a fresh transaction.
<S extends Store>
WorkflowStore
WorkflowStoreService.create(S store)
          Return a workflow store instance with an existing transaction.
<S extends Store>
SLAStore
SLAStoreService.create(S store)
          Return a SLA store instance with an existing transaction.
<S extends Store>
WorkflowStore
DBLiteWorkflowStoreService.create(S store)
           
<S extends Store>
CoordinatorStore
CoordinatorStoreService.create(S store)
          Return a workflow store instance with an existing transaction.
<S extends Store>
S
StoreService.getStore(Class<S> klass)
          Return instance of store.
<S extends Store,T extends Store>
S
StoreService.getStore(Class<S> klass, T store)
          Return instance of store with an EntityManager pointing to an existing Store.
 

Uses of StoreException in org.apache.oozie.store
 

Methods in org.apache.oozie.store that throw StoreException
 void CoordinatorStore.close()
           
 void CoordinatorStore.commit()
           
 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.
 Integer CoordinatorStore.getActionsForCoordinatorJob(String jobId, boolean locking)
          Loads all actions for the given Coordinator job.
 List<WorkflowActionBean> WorkflowStore.getActionsForWorkflow(String wfId, boolean locking)
          Loads all the actions for the given Workflow.
 List<CoordinatorActionBean> CoordinatorStore.getActionsSubsetForCoordinatorJob(String jobId, int start, int len)
          Loads given number of actions for the given Coordinator job.
 List<WorkflowActionBean> WorkflowStore.getActionsSubsetForWorkflow(String wfId, int start, int len)
          Loads given number of actions for the given Workflow.
 CoordinatorActionBean CoordinatorStore.getCoordActionForNominalTime(String jobId, Date nominalTime)
          Get coordinator action bean for given date
 List<CoordinatorActionBean> CoordinatorStore.getCoordActionsForDates(String jobId, Date startDate, Date endDate)
          Get coordinator action beans for given start date and end date
 CoordinatorActionBean CoordinatorStore.getCoordinatorAction(String id, boolean locking)
          Load the CoordinatorAction into a Bean and return it.
 List<CoordinatorActionBean> CoordinatorStore.getCoordinatorActionsForJob(String id, int numResults, String executionOrder)
          Return CoordinatorActions for a jobID.
 CoordinatorJobInfo CoordinatorStore.getCoordinatorInfo(Map<String,List<String>> filter, int start, int len)
           
 CoordinatorJobBean CoordinatorStore.getCoordinatorJob(String id, boolean locking)
          Load the CoordinatorJob into a Bean and return it.
 List<CoordinatorJobBean> CoordinatorStore.getCoordinatorJobsOlderThanStatus(long checkAgeSecs, String status, int limit, boolean locking)
          A list of Coordinator Jobs that are matched with the status and have last materialized time' older than checkAgeSecs will be returned.
 List<CoordinatorJobBean> CoordinatorStore.getCoordinatorJobsToBeMaterialized(Date d, int limit)
          Get a list of Coordinator Jobs that should be materialized.
 int CoordinatorStore.getCoordinatorRunningActionsCount(String id)
          Return CoordinatorActions for a jobID.
 List<WorkflowActionBean> WorkflowStore.getPendingActions(long minimumPendingAgeSecs)
          Load All the actions that are pending for more than given time.
 List<String> CoordinatorStore.getRecoveryActionsGroupByJobId(long checkAgeSecs)
           
 List<CoordinatorActionBean> CoordinatorStore.getRecoveryActionsOlderThan(long checkAgeSecs, boolean locking)
           
 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<CoordinatorActionBean> CoordinatorStore.getRunningActionsForCoordinatorJob(String jobId, boolean locking)
           
 List<CoordinatorActionBean> CoordinatorStore.getRunningActionsOlderThan(long checkAgeSecs, boolean locking)
           
 List<SLAEventBean> SLAStore.getSLAEventListNewerSeqLimited(long seqId, int limitLen, long[] lastSeqId)
          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 CoordinatorStore.insertCoordinatorAction(CoordinatorActionBean action)
          Create a new Action record in the ACTIONS table with the given Bean.
 void CoordinatorStore.insertCoordinatorJob(CoordinatorJobBean coordinatorJob)
          Create a CoordJobBean.
 void SLAStore.insertSLAEvent(SLAEventBean slaEvent)
          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 CoordinatorStore.purge(long olderThanDays, int limit)
          Purge the coordinators completed older than given days.
 void WorkflowStore.updateAction(WorkflowActionBean action)
          Update the given action bean to DB.
 void CoordinatorStore.updateCoordActionMin(CoordinatorActionBean action)
          Update the given action bean to DB.
 void CoordinatorStore.updateCoordinatorAction(CoordinatorActionBean action)
          Update the given action bean to DB.
 void CoordinatorStore.updateCoordinatorJob(CoordinatorJobBean job)
          Update the given coordinator job bean to DB.
 void CoordinatorStore.updateCoordinatorJobStatus(CoordinatorJobBean job)
           
 void WorkflowStore.updateWorkflow(WorkflowJobBean wfBean)
          Update the data from Workflow Bean to DB along with the workflow instance data.
 

Constructors in org.apache.oozie.store that throw StoreException
CoordinatorStore(boolean selectForUpdate)
           
CoordinatorStore(Store store, boolean selectForUpdate)
           
SLAStore()
           
SLAStore(Store store)
           
WorkflowStore(boolean selectForUpdate)
           
WorkflowStore(Connection connection, boolean selectForUpdate)
           
WorkflowStore(Connection connection, Store store, boolean selectForUpdate)
           
WorkflowStore(Store store, boolean selectForUpdate)
           
 



Copyright © 2013 Apache Software Foundation. All Rights Reserved.