Uses of Class
org.apache.oozie.executor.jpa.JPAExecutorException

Packages that use JPAExecutorException

Package	Description
org.apache.oozie.executor.jpa
org.apache.oozie.executor.jpa.sla
org.apache.oozie.service
org.apache.oozie.sla
org.apache.oozie.store

Uses of JPAExecutorException in org.apache.oozie.executor.jpa

Methods in org.apache.oozie.executor.jpa that throw JPAExecutorException

Modifier and Type	Method and Description
WorkflowsInfo	WorkflowsJobGetJPAExecutor.execute(javax.persistence.EntityManager em)
List<String>	WorkflowJobsGetFromWorkflowParentIdJPAExecutor.execute(javax.persistence.EntityManager em)
List<String>	WorkflowJobsGetFromCoordParentIdJPAExecutor.execute(javax.persistence.EntityManager em)
List<String>	WorkflowJobsGetForPurgeJPAExecutor.execute(javax.persistence.EntityManager em)
Integer	WorkflowJobsDeleteJPAExecutor.execute(javax.persistence.EntityManager em)
Long	WorkflowJobsCountNotForPurgeFromWorkflowParentIdJPAExecutor.execute(javax.persistence.EntityManager em)
Long	WorkflowJobsCountNotForPurgeFromCoordParentIdJPAExecutor.execute(javax.persistence.EntityManager em)
String	WorkflowJobInsertJPAExecutor.execute(javax.persistence.EntityManager em)
WorkflowJobBean	WorkflowJobGetJPAExecutor.execute(javax.persistence.EntityManager em)
String	WorkflowJobGetForUserJPAExecutor.execute(javax.persistence.EntityManager em)
WorkflowJobBean	WorkflowJobGetForSLAJPAExecutor.execute(javax.persistence.EntityManager em)
List<WorkflowActionBean>	WorkflowJobGetActionsJPAExecutor.execute(javax.persistence.EntityManager em)
Void	WorkflowJobDeleteJPAExecutor.execute(javax.persistence.EntityManager em)
WorkflowJobBean	WorkflowInfoWithActionsSubsetGetJPAExecutor.execute(javax.persistence.EntityManager em)
String	WorkflowIdGetForExternalIdJPAExecutor.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)
String	WorkflowActionInsertJPAExecutor.execute(javax.persistence.EntityManager em)
WorkflowActionBean	WorkflowActionGetJPAExecutor.execute(javax.persistence.EntityManager em)
WorkflowActionBean	WorkflowActionGetForSLAJPAExecutor.execute(javax.persistence.EntityManager em)
Void	WorkflowActionDeleteJPAExecutor.execute(javax.persistence.EntityManager em)
List<SLAEventBean>	SLAEventsGetJPAExecutor.execute(javax.persistence.EntityManager em) Deprecated.
List<SLAEventBean>	SLAEventsGetForSeqIdJPAExecutor.execute(javax.persistence.EntityManager em) Deprecated.
List<SLAEventBean>	SLAEventsGetForFilterJPAExecutor.execute(javax.persistence.EntityManager em) Deprecated.
String	SLAEventInsertJPAExecutor.execute(javax.persistence.EntityManager em) Deprecated.
T	JPAExecutor.execute(javax.persistence.EntityManager em) Method that encapsulates JPA access operations.
List<CoordinatorJobBean>	CoordJobsToBeMaterializedJPAExecutor.execute(javax.persistence.EntityManager em)
List<CoordinatorJobBean>	CoordJobsGetUnpausedJPAExecutor.execute(javax.persistence.EntityManager em)
List<CoordinatorJobBean>	CoordJobsGetPendingJPAExecutor.execute(javax.persistence.EntityManager em)
List<CoordinatorJobBean>	CoordJobsGetPausedJPAExecutor.execute(javax.persistence.EntityManager em)
List<String>	CoordJobsGetFromParentIdJPAExecutor.execute(javax.persistence.EntityManager em)
List<String>	CoordJobsGetForPurgeJPAExecutor.execute(javax.persistence.EntityManager em)
Integer	CoordJobsDeleteJPAExecutor.execute(javax.persistence.EntityManager em)
Long	CoordJobsCountNotForPurgeFromParentIdJPAExecutor.execute(javax.persistence.EntityManager em)
String	CoordJobInsertJPAExecutor.execute(javax.persistence.EntityManager em)
CoordinatorJobInfo	CoordJobInfoGetJPAExecutor.execute(javax.persistence.EntityManager em)
Integer	CoordJobGetRunningActionsCountJPAExecutor.execute(javax.persistence.EntityManager em)
List<CoordinatorActionBean>	CoordJobGetReadyActionsJPAExecutor.execute(javax.persistence.EntityManager em)
Integer	CoordJobGetPendingActionsCountJPAExecutor.execute(javax.persistence.EntityManager em)
CoordinatorJobBean	CoordJobGetJPAExecutor.execute(javax.persistence.EntityManager em)
List<CoordinatorActionBean>	CoordJobGetActionsSuspendedJPAExecutor.execute(javax.persistence.EntityManager em)
List<CoordinatorActionBean>	CoordJobGetActionsSubsetJPAExecutor.execute(javax.persistence.EntityManager em)
List<org.apache.oozie.client.CoordinatorAction.Status>	CoordJobGetActionsStatusJPAExecutor.execute(javax.persistence.EntityManager em)
List<CoordinatorActionBean>	CoordJobGetActionsRunningJPAExecutor.execute(javax.persistence.EntityManager em)
List<CoordinatorActionBean>	CoordJobGetActionsNotCompletedJPAExecutor.execute(javax.persistence.EntityManager em)
Integer	CoordJobGetActionsJPAExecutor.execute(javax.persistence.EntityManager em)
List<CoordinatorActionBean>	CoordJobGetActionsForDatesJPAExecutor.execute(javax.persistence.EntityManager em)
List<CoordinatorActionBean>	CoordJobGetActionsByDatesForKillJPAExecutor.execute(javax.persistence.EntityManager em)
Long	CoordJobGetActionRunningCountForRangeJPAExecutor.execute(javax.persistence.EntityManager em)
Date	CoordJobGetActionModifiedDateForRangeJPAExecutor.execute(javax.persistence.EntityManager em)
List<String>	CoordJobGetActionIdsForDateRangeJPAExecutor.execute(javax.persistence.EntityManager em)
CoordinatorActionBean	CoordJobGetActionForNominalTimeJPAExecutor.execute(javax.persistence.EntityManager em)
String	CoordJobGetActionByActionNumberJPAExecutor.execute(javax.persistence.EntityManager em)
Void	CoordJobDeleteJPAExecutor.execute(javax.persistence.EntityManager em)
String	CoordinatorJobGetForUserJPAExecutor.execute(javax.persistence.EntityManager em)
CoordinatorJobBean	CoordinatorJobGetForUserAppnameJPAExecutor.execute(javax.persistence.EntityManager em)
List<String>	CoordActionsRunningGetJPAExecutor.execute(javax.persistence.EntityManager em)
Integer	CoordActionsPendingFalseStatusCountGetJPAExecutor.execute(javax.persistence.EntityManager em)
Integer	CoordActionsPendingFalseCountGetJPAExecutor.execute(javax.persistence.EntityManager em)
List<String>	CoordActionsGetReadyGroupbyJobIDJPAExecutor.execute(javax.persistence.EntityManager em)
List<CoordinatorActionBean>	CoordActionsGetForRecoveryJPAExecutor.execute(javax.persistence.EntityManager em)
Integer	CoordActionsDeleteJPAExecutor.execute(javax.persistence.EntityManager em)
Integer	CoordActionsCountForJobIdJPAExecutor.execute(javax.persistence.EntityManager em)
Integer	CoordActionsActiveCountJPAExecutor.execute(javax.persistence.EntityManager em)
Void	CoordActionRemoveJPAExecutor.execute(javax.persistence.EntityManager em)
String	CoordActionInsertJPAExecutor.execute(javax.persistence.EntityManager em)
CoordinatorActionBean	CoordActionGetJPAExecutor.execute(javax.persistence.EntityManager em)
CoordinatorActionBean	CoordActionGetForTimeoutJPAExecutor.execute(javax.persistence.EntityManager em)
CoordinatorActionBean	CoordActionGetForStartJPAExecutor.execute(javax.persistence.EntityManager em)
CoordinatorActionBean	CoordActionGetForSLAJPAExecutor.execute(javax.persistence.EntityManager em)
CoordinatorActionBean	CoordActionGetForInputCheckJPAExecutor.execute(javax.persistence.EntityManager em)
CoordinatorActionBean	CoordActionGetForInfoJPAExecutor.execute(javax.persistence.EntityManager em)
CoordinatorActionBean	CoordActionGetForExternalIdJPAExecutor.execute(javax.persistence.EntityManager em)
CoordinatorActionBean	CoordActionGetForCheckJPAExecutor.execute(javax.persistence.EntityManager em)
List<BundleJobBean>	BundleJobsGetUnpausedJPAExecutor.execute(javax.persistence.EntityManager em)
List<BundleJobBean>	BundleJobsGetRunningOrPendingJPAExecutor.execute(javax.persistence.EntityManager em)
List<BundleJobBean>	BundleJobsGetPausedJPAExecutor.execute(javax.persistence.EntityManager em)
List<BundleJobBean>	BundleJobsGetNeedStartJPAExecutor.execute(javax.persistence.EntityManager em)
List<String>	BundleJobsGetForPurgeJPAExecutor.execute(javax.persistence.EntityManager em)
Integer	BundleJobsDeleteJPAExecutor.execute(javax.persistence.EntityManager em)
String	BundleJobInsertJPAExecutor.execute(javax.persistence.EntityManager em)
BundleJobInfo	BundleJobInfoGetJPAExecutor.execute(javax.persistence.EntityManager em)
BundleJobBean	BundleJobGetJPAExecutor.execute(javax.persistence.EntityManager em)
String	BundleJobGetForUserJPAExecutor.execute(javax.persistence.EntityManager em)
List<CoordinatorJobBean>	BundleJobGetCoordinatorsJPAExecutor.execute(javax.persistence.EntityManager em)
Integer	BundleActionsCountForJobGetJPAExecutor.execute(javax.persistence.EntityManager em)
Void	BundleActionInsertJPAExecutor.execute(javax.persistence.EntityManager em)
BundleActionBean	BundleActionGetJPAExecutor.execute(javax.persistence.EntityManager em)
BulkResponseInfo	BulkJPAExecutor.execute(javax.persistence.EntityManager em)
void	BatchQueryExecutor.executeBatchInsertUpdateDelete(Collection<JsonBean> insertList, Collection<BatchQueryExecutor.UpdateEntry> updateList, Collection<JsonBean> deleteList)
int	BundleActionQueryExecutor.executeUpdate(BundleActionQueryExecutor.BundleActionQuery namedQuery, BundleActionBean jobBean)
int	BundleJobQueryExecutor.executeUpdate(BundleJobQueryExecutor.BundleJobQuery namedQuery, BundleJobBean jobBean)
int	CoordActionQueryExecutor.executeUpdate(CoordActionQueryExecutor.CoordActionQuery namedQuery, CoordinatorActionBean jobBean)
int	CoordJobQueryExecutor.executeUpdate(CoordJobQueryExecutor.CoordJobQuery namedQuery, CoordinatorJobBean jobBean)
abstract int	QueryExecutor.executeUpdate(E namedQuery, T jobBean)
int	SLARegistrationQueryExecutor.executeUpdate(SLARegistrationQueryExecutor.SLARegQuery namedQuery, SLARegistrationBean jobBean)
int	SLASummaryQueryExecutor.executeUpdate(SLASummaryQueryExecutor.SLASummaryQuery namedQuery, SLASummaryBean jobBean)
int	WorkflowActionQueryExecutor.executeUpdate(WorkflowActionQueryExecutor.WorkflowActionQuery namedQuery, WorkflowActionBean actionBean)
int	WorkflowJobQueryExecutor.executeUpdate(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery, WorkflowJobBean jobBean)
BundleActionBean	BundleActionQueryExecutor.get(BundleActionQueryExecutor.BundleActionQuery namedQuery, Object... parameters)
BundleJobBean	BundleJobQueryExecutor.get(BundleJobQueryExecutor.BundleJobQuery namedQuery, Object... parameters)
CoordinatorActionBean	CoordActionQueryExecutor.get(CoordActionQueryExecutor.CoordActionQuery namedQuery, Object... parameters)
CoordinatorJobBean	CoordJobQueryExecutor.get(CoordJobQueryExecutor.CoordJobQuery namedQuery, Object... parameters)
abstract T	QueryExecutor.get(E namedQuery, Object... parameters)
SLARegistrationBean	SLARegistrationQueryExecutor.get(SLARegistrationQueryExecutor.SLARegQuery namedQuery, Object... parameters)
SLASummaryBean	SLASummaryQueryExecutor.get(SLASummaryQueryExecutor.SLASummaryQuery namedQuery, Object... parameters)
WorkflowActionBean	WorkflowActionQueryExecutor.get(WorkflowActionQueryExecutor.WorkflowActionQuery namedQuery, Object... parameters)
WorkflowJobBean	WorkflowJobQueryExecutor.get(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery, Object... parameters)
List<BundleActionBean>	BundleActionQueryExecutor.getList(BundleActionQueryExecutor.BundleActionQuery namedQuery, Object... parameters)
List<BundleJobBean>	BundleJobQueryExecutor.getList(BundleJobQueryExecutor.BundleJobQuery namedQuery, Object... parameters)
List<CoordinatorActionBean>	CoordActionQueryExecutor.getList(CoordActionQueryExecutor.CoordActionQuery namedQuery, Object... parameters)
List<CoordinatorJobBean>	CoordJobQueryExecutor.getList(CoordJobQueryExecutor.CoordJobQuery namedQuery, Object... parameters)
abstract List<T>	QueryExecutor.getList(E namedQuery, Object... parameters)
List<SLARegistrationBean>	SLARegistrationQueryExecutor.getList(SLARegistrationQueryExecutor.SLARegQuery namedQuery, Object... parameters)
List<SLASummaryBean>	SLASummaryQueryExecutor.getList(SLASummaryQueryExecutor.SLASummaryQuery namedQuery, Object... parameters)
List<WorkflowActionBean>	WorkflowActionQueryExecutor.getList(WorkflowActionQueryExecutor.WorkflowActionQuery namedQuery, Object... parameters)
List<WorkflowJobBean>	WorkflowJobQueryExecutor.getList(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery, Object... parameters)
javax.persistence.Query	BundleActionQueryExecutor.getSelectQuery(BundleActionQueryExecutor.BundleActionQuery namedQuery, javax.persistence.EntityManager em, Object... parameters)
javax.persistence.Query	BundleJobQueryExecutor.getSelectQuery(BundleJobQueryExecutor.BundleJobQuery namedQuery, javax.persistence.EntityManager em, Object... parameters)
javax.persistence.Query	CoordActionQueryExecutor.getSelectQuery(CoordActionQueryExecutor.CoordActionQuery namedQuery, javax.persistence.EntityManager em, Object... parameters)
javax.persistence.Query	CoordJobQueryExecutor.getSelectQuery(CoordJobQueryExecutor.CoordJobQuery namedQuery, javax.persistence.EntityManager em, Object... parameters)
abstract javax.persistence.Query	QueryExecutor.getSelectQuery(E namedQuery, javax.persistence.EntityManager em, Object... parameters)
javax.persistence.Query	SLARegistrationQueryExecutor.getSelectQuery(SLARegistrationQueryExecutor.SLARegQuery namedQuery, javax.persistence.EntityManager em, Object... parameters)
javax.persistence.Query	SLASummaryQueryExecutor.getSelectQuery(SLASummaryQueryExecutor.SLASummaryQuery namedQuery, javax.persistence.EntityManager em, Object... parameters)
javax.persistence.Query	WorkflowActionQueryExecutor.getSelectQuery(WorkflowActionQueryExecutor.WorkflowActionQuery namedQuery, javax.persistence.EntityManager em, Object... parameters)
javax.persistence.Query	WorkflowJobQueryExecutor.getSelectQuery(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery, javax.persistence.EntityManager em, Object... parameters)
Object	BundleActionQueryExecutor.getSingleValue(BundleActionQueryExecutor.BundleActionQuery namedQuery, Object... parameters)
Object	BundleJobQueryExecutor.getSingleValue(BundleJobQueryExecutor.BundleJobQuery namedQuery, Object... parameters)
Object	CoordActionQueryExecutor.getSingleValue(CoordActionQueryExecutor.CoordActionQuery namedQuery, Object... parameters)
Object	CoordJobQueryExecutor.getSingleValue(CoordJobQueryExecutor.CoordJobQuery namedQuery, Object... parameters)
abstract Object	QueryExecutor.getSingleValue(E namedQuery, Object... parameters)
Object	SLARegistrationQueryExecutor.getSingleValue(SLARegistrationQueryExecutor.SLARegQuery namedQuery, Object... parameters)
Object	SLASummaryQueryExecutor.getSingleValue(SLASummaryQueryExecutor.SLASummaryQuery namedQuery, Object... parameters)
Object	WorkflowActionQueryExecutor.getSingleValue(WorkflowActionQueryExecutor.WorkflowActionQuery namedQuery, Object... parameters)
Object	WorkflowJobQueryExecutor.getSingleValue(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery, Object... parameters)
javax.persistence.Query	BundleActionQueryExecutor.getUpdateQuery(BundleActionQueryExecutor.BundleActionQuery namedQuery, BundleActionBean baBean, javax.persistence.EntityManager em)
javax.persistence.Query	BundleJobQueryExecutor.getUpdateQuery(BundleJobQueryExecutor.BundleJobQuery namedQuery, BundleJobBean bjBean, javax.persistence.EntityManager em)
javax.persistence.Query	CoordActionQueryExecutor.getUpdateQuery(CoordActionQueryExecutor.CoordActionQuery namedQuery, CoordinatorActionBean actionBean, javax.persistence.EntityManager em)
javax.persistence.Query	CoordJobQueryExecutor.getUpdateQuery(CoordJobQueryExecutor.CoordJobQuery namedQuery, CoordinatorJobBean cjBean, javax.persistence.EntityManager em)
abstract javax.persistence.Query	QueryExecutor.getUpdateQuery(E namedQuery, T wfBean, javax.persistence.EntityManager em)
javax.persistence.Query	SLARegistrationQueryExecutor.getUpdateQuery(SLARegistrationQueryExecutor.SLARegQuery namedQuery, SLARegistrationBean bean, javax.persistence.EntityManager em)
javax.persistence.Query	SLASummaryQueryExecutor.getUpdateQuery(SLASummaryQueryExecutor.SLASummaryQuery namedQuery, SLASummaryBean bean, javax.persistence.EntityManager em)
javax.persistence.Query	WorkflowActionQueryExecutor.getUpdateQuery(WorkflowActionQueryExecutor.WorkflowActionQuery namedQuery, WorkflowActionBean actionBean, javax.persistence.EntityManager em)
javax.persistence.Query	WorkflowJobQueryExecutor.getUpdateQuery(WorkflowJobQueryExecutor.WorkflowJobQuery namedQuery, WorkflowJobBean wfBean, javax.persistence.EntityManager em)
void	QueryExecutor.insert(JsonBean bean)

Uses of JPAExecutorException in org.apache.oozie.executor.jpa.sla

Methods in org.apache.oozie.executor.jpa.sla that throw JPAExecutorException

Modifier and Type	Method and Description
List<SLASummaryBean>	SLASummaryGetRecordsOnRestartJPAExecutor.execute(javax.persistence.EntityManager em)
List<SLASummaryBean>	SLASummaryGetForFilterJPAExecutor.execute(javax.persistence.EntityManager em)

Uses of JPAExecutorException in org.apache.oozie.service

Methods in org.apache.oozie.service that throw JPAExecutorException

Modifier and Type	Method and Description
<T> T	JPAService.execute(JPAExecutor<T> executor) Execute a JPAExecutor.
void	JPAService.executeBatchInsertUpdateDelete(Collection<JsonBean> insertBeans, List<JPAService.QueryEntry> updateQueryList, Collection<JsonBean> deleteBeans, javax.persistence.EntityManager em) Execute multiple update/insert queries in one transaction
int	JPAService.executeUpdate(String namedQueryName, javax.persistence.Query query, javax.persistence.EntityManager em) Execute an UPDATE query
String	JMSTopicService.getTopic(String jobId) Retrieve topic from Job id

Uses of JPAExecutorException in org.apache.oozie.sla

Methods in org.apache.oozie.sla that throw JPAExecutorException

Modifier and Type	Method and Description
boolean	SLACalculatorMemory.addJobStatus(String jobId, String jobStatus, org.apache.oozie.client.event.JobEvent.EventStatus jobEventStatus, Date startTime, Date endTime) Triggered after receiving Job status change event, update SLA status accordingly
boolean	SLACalculator.addJobStatus(String jobId, String jobStatus, org.apache.oozie.client.event.JobEvent.EventStatus jobEventStatus, Date startTime, Date endTime)
boolean	SLACalculatorMemory.addRegistration(String jobId, SLARegistrationBean reg) Register a new job into the map for SLA tracking
boolean	SLACalculator.addRegistration(String jobId, SLARegistrationBean reg)
SLACalcStatus	SLACalculatorMemory.get(String jobId)
SLACalcStatus	SLACalculator.get(String jobId)
boolean	SLACalculatorMemory.updateRegistration(String jobId, SLARegistrationBean reg) Update job into the map for SLA tracking
boolean	SLACalculator.updateRegistration(String jobId, SLARegistrationBean reg)
static void	SLAOperations.updateRegistrationEvent(String jobId) Retrieve registration event

Uses of JPAExecutorException in org.apache.oozie.store

Methods in org.apache.oozie.store that throw JPAExecutorException

Modifier and Type	Method and Description
void	CoordinatorStore.updateCoordActionMin(CoordinatorActionBean action) Update the given action bean to DB.
void	CoordinatorStore.updateCoordinatorAction(CoordinatorActionBean action) Update the given action bean to DB.