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

Packages that use JPAExecutorException

org.apache.oozie.executor.jpa
org.apache.oozie.executor.jpa.sla
org.apache.oozie.service
org.apache.oozie.sla

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

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

WorkflowsInfo	WorkflowsJobGetJPAExecutor.execute(javax.persistence.EntityManager em)
Void	WorkflowJobUpdateJPAExecutor.execute(javax.persistence.EntityManager em)
List<String>	WorkflowJobsGetFromParentIdJPAExecutor.execute(javax.persistence.EntityManager em)
List<String>	WorkflowJobsGetForPurgeJPAExecutor.execute(javax.persistence.EntityManager em)
Integer	WorkflowJobsDeleteJPAExecutor.execute(javax.persistence.EntityManager em)
Long	WorkflowJobsCountNotForPurgeFromParentIdJPAExecutor.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)
String	WorkflowActionUpdateJPAExecutor.execute(javax.persistence.EntityManager em)
List<WorkflowActionBean>	WorkflowActionSubsetGetJPAExecutor.execute(javax.persistence.EntityManager em)
List<WorkflowActionBean>	WorkflowActionsRunningGetJPAExecutor.execute(javax.persistence.EntityManager em)
List<WorkflowActionBean>	WorkflowActionsGetPendingJPAExecutor.execute(javax.persistence.EntityManager em) Load All the actions that are pending for more than given time.
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.
Void	CoordJobUpdateJPAExecutor.execute(javax.persistence.EntityManager em)
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<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)
Void	CoordActionUpdateStatusJPAExecutor.execute(javax.persistence.EntityManager em)
Void	CoordActionUpdatePushInputCheckJPAExecutor.execute(javax.persistence.EntityManager em)
Void	CoordActionUpdateJPAExecutor.execute(javax.persistence.EntityManager em)
Void	CoordActionUpdateForModifiedTimeJPAExecutor.execute(javax.persistence.EntityManager em)
Void	CoordActionUpdateForInputCheckJPAExecutor.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)
List<String>	CoordActionsGetByLastModifiedTimeJPAExecutor.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)
Void	BundleJobUpdateJPAExecutor.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)
Void	BundleActionUpdateJPAExecutor.execute(javax.persistence.EntityManager em)
List<BundleActionBean>	BundleActionsGetWaitingOlderJPAExecutor.execute(javax.persistence.EntityManager em)
List<BundleActionBean>	BundleActionsGetStatusPendingJPAExecutor.execute(javax.persistence.EntityManager em)
List<BundleActionBean>	BundleActionsGetJPAExecutor.execute(javax.persistence.EntityManager em)
List<BundleActionBean>	BundleActionsGetByLastModifiedTimeJPAExecutor.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)
Void	BulkUpdateInsertJPAExecutor.execute(javax.persistence.EntityManager em)
Void	BulkUpdateInsertForCoordActionStatusJPAExecutor.execute(javax.persistence.EntityManager em)
Void	BulkUpdateInsertForCoordActionStartJPAExecutor.execute(javax.persistence.EntityManager em)
Void	BulkUpdateDeleteJPAExecutor.execute(javax.persistence.EntityManager em)
BulkResponseInfo	BulkJPAExecutor.execute(javax.persistence.EntityManager em)

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

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

Void	SLASummaryUpdateForSLAStatusActualTimesJPAExecutor.execute(javax.persistence.EntityManager em)
List<SLASummaryBean>	SLASummaryGetRecordsOnRestartJPAExecutor.execute(javax.persistence.EntityManager em)
SLASummaryBean	SLASummaryGetJPAExecutor.execute(javax.persistence.EntityManager em)
List<SLASummaryBean>	SLASummaryGetForFilterJPAExecutor.execute(javax.persistence.EntityManager em)
SLARegistrationBean	SLARegistrationGetOnRestartJPAExecutor.execute(javax.persistence.EntityManager em)
SLARegistrationBean	SLARegistrationGetJPAExecutor.execute(javax.persistence.EntityManager em)
String	SLACalculationInsertUpdateJPAExecutor.execute(javax.persistence.EntityManager em)

Uses of JPAExecutorException in org.apache.oozie.service

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

<T> T	JPAService.execute(JPAExecutor<T> executor) Execute a JPAExecutor.
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

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)
protected void	SLACalculatorMemory.updateJobSla(String jobId) Invoked via periodic run, update the SLA for registered jobs
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