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

Packages that use StoreException

org.apache.oozie.command
org.apache.oozie.command.coord
org.apache.oozie.command.wf
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	CoordSuspendCommand.call(CoordinatorStore store)
protected String	CoordSubmitCommand.call(CoordinatorStore store)
protected Void	CoordResumeCommand.call(CoordinatorStore store)
protected CoordinatorActionInfo	CoordRerunCommand.call(CoordinatorStore store)
protected Void	CoordRecoveryCommand.call(CoordinatorStore store)
protected Void	CoordPurgeCommand.call(CoordinatorStore store)
protected Void	CoordKillCommand.call(CoordinatorStore store)
protected CoordinatorJobInfo	CoordJobsCommand.call(CoordinatorStore store)
protected Void	CoordJobMatLookupCommand.call(CoordinatorStore store)
protected CoordinatorJobBean	CoordJobCommand.call(CoordinatorStore store)
protected Void	CoordChangeCommand.call(CoordinatorStore store)
protected Void	CoordActionUpdateCommand.call(CoordinatorStore cstore)
protected Void	CoordActionTimeOut.call(CoordinatorStore store)
protected Void	CoordActionStartCommand.call(CoordinatorStore store)
protected Void	CoordActionReadyCommand.call(CoordinatorStore store)
protected Void	CoordActionNotification.call(CoordinatorStore store)
protected Void	CoordActionMaterializeCommand.call(CoordinatorStore store)
protected Void	CoordActionInputCheckCommand.call(CoordinatorStore store)
protected CoordinatorActionBean	CoordActionInfoCommand.call(CoordinatorStore store)
protected Void	CoordActionCheckCommand.call(CoordinatorStore cstore)
protected List<SLAEventBean>	SLAEventsCommand.call(SLAStore store)
protected Void	CoordSuspendCommand.execute(CoordinatorStore store)
protected Void	CoordResumeCommand.execute(CoordinatorStore store)
protected CoordinatorActionInfo	CoordRerunCommand.execute(CoordinatorStore store)
protected Void	CoordRecoveryCommand.execute(CoordinatorStore store)
protected Void	CoordKillCommand.execute(CoordinatorStore store)
protected Void	CoordJobMatLookupCommand.execute(CoordinatorStore store)
protected Void	CoordChangeCommand.execute(CoordinatorStore store)
protected Void	CoordActionUpdateCommand.execute(CoordinatorStore store)
protected Void	CoordActionTimeOut.execute(CoordinatorStore store)
protected Void	CoordActionStartCommand.execute(CoordinatorStore store)
protected Void	CoordActionReadyCommand.execute(CoordinatorStore store)
protected Void	CoordActionMaterializeCommand.execute(CoordinatorStore store)
protected Void	CoordActionInputCheckCommand.execute(CoordinatorStore store)
protected Void	CoordActionCheckCommand.execute(CoordinatorStore store)

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

Methods in org.apache.oozie.command.wf that throw StoreException

protected WorkflowActionBean	WorkflowActionInfoCommand.call(WorkflowStore store)
protected Void	SuspendCommand.call(WorkflowStore store)
protected String	SubmitHttpCommand.call(WorkflowStore store)
protected String	SubmitCommand.call(WorkflowStore store)
protected Void	SignalCommand.call(WorkflowStore store)
protected Void	ResumeCommand.call(WorkflowStore store)
protected Void	ReRunCommand.call(WorkflowStore store)
protected Void	PurgeCommand.call(WorkflowStore store)
protected Void	KillCommand.call(WorkflowStore store)
protected WorkflowsInfo	JobsCommand.call(WorkflowStore store)
protected WorkflowJobBean	JobCommand.call(WorkflowStore store)
protected String	ExternalIdCommand.call(WorkflowStore store)
protected String	DefinitionCommand.call(WorkflowStore store)
protected Void	CompletedActionCommand.call(WorkflowStore store)
protected Void	ActionStartCommand.call(WorkflowStore store)
protected Void	ActionKillCommand.call(WorkflowStore store)
protected Void	ActionEndCommand.call(WorkflowStore store)
protected Void	ActionCheckCommand.call(WorkflowStore store)
protected Void	SuspendCommand.execute(WorkflowStore store)
protected Void	SignalCommand.execute(WorkflowStore store)
protected Void	ResumeCommand.execute(WorkflowStore store)
protected Void	ReRunCommand.execute(WorkflowStore store)
protected Void	KillCommand.execute(WorkflowStore store)
protected Void	ActionStartCommand.execute(WorkflowStore store)
protected Void	ActionKillCommand.execute(WorkflowStore store)
protected Void	ActionEndCommand.execute(WorkflowStore store)
protected Void	ActionCheckCommand.execute(WorkflowStore store)
protected void	ActionCommand.handleNonTransient(WorkflowStore store, ActionExecutor.Context context, ActionExecutor executor, org.apache.oozie.client.WorkflowAction.Status status) Takes care of non transient failures.
protected boolean	ActionCommand.handleTransient(ActionExecutor.Context context, ActionExecutor executor, org.apache.oozie.client.WorkflowAction.Status status) Takes care of Transient failures.
static void	SuspendCommand.setPendingFalseForActions(WorkflowStore store, String id, String actionId) Set pending flag to false for the actions that are START_RETRY or START_MANUAL or END_RETRY or END_MANUAL
static void	SuspendCommand.suspendJob(WorkflowStore store, WorkflowJobBean workflow, String id, String actionId) 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

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.
List<CoordinatorActionBean>	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.
CoordinatorActionBean	CoordinatorStore.getCoordinatorActionForExternalId(String externalId)
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)