Package org.apache.oozie.executor.jpa

Interface Summary

JPAExecutor<T>

Executor pattern interface that gives access to an EntityManager.

Class Summary

BulkDeleteForPurgeJPAExecutor	Delete job, its list of actions and return the number of actions been deleted.
BulkJPAExecutor	The query executor class for bulk monitoring queries i.e.
BulkUpdateDeleteJPAExecutor	Class for updating and deleting beans in bulk
BulkUpdateInsertForCoordActionStartJPAExecutor	Class for inserting and updating beans in bulk
BulkUpdateInsertForCoordActionStatusJPAExecutor	Class for inserting and updating beans in bulk
BulkUpdateInsertJPAExecutor	Class for inserting and updating beans in bulk
BundleActionGetJPAExecutor	Load the BundleAction into a Bean and return it.
BundleActionInsertJPAExecutor	Persist the BundleAction bean.
BundleActionsCountForJobGetJPAExecutor	Load the number of actions for a bundle job.
BundleActionsGetByLastModifiedTimeJPAExecutor	Load the list of BundleAction ordered by lastModifiedTime
BundleActionsGetJPAExecutor	Load the list of BundleAction return it.
BundleActionsGetStatusPendingJPAExecutor	Load the list of BundleAction return it.
BundleActionsGetWaitingOlderJPAExecutor
BundleActionUpdateJPAExecutor	Update the given bundle action bean to DB.
BundleJobGetCoordinatorsJPAExecutor	Load the coordinators for specified bundle in the Coordinator job bean
BundleJobGetJPAExecutor	Load the BundleJob into a Bean and return it.
BundleJobInfoGetJPAExecutor	Load the BundleInfo and return it.
BundleJobInsertJPAExecutor	Persist the BundleJob bean.
BundleJobsGetForPurgeJPAExecutor	Load the list of completed BundleJob for purge ready.
BundleJobsGetNeedStartJPAExecutor	Get a list of bundle Jobs that need to be started;
BundleJobsGetPausedJPAExecutor	Get a list of paused bundle Jobs;
BundleJobsGetRunningOrPendingJPAExecutor	Get a list of Bundle Jobs that are are RUNNING or RUNNINGWITHERROR status or the pending flag is 1.
BundleJobsGetUnpausedJPAExecutor	Get a list of unpaused bundle Jobs;
BundleJobUpdateJPAExecutor	Update the given bundle job bean to DB.
CoordActionGetForCheckJPAExecutor	JPAExecutor to get attributes of CoordinatorActionBean required by CoordActionCheckCommand
CoordActionGetForExternalIdJPAExecutor	Load coordinator action by externalId.
CoordActionGetForInfoJPAExecutor	Load the CoordinatorAction into a Bean and return it.
CoordActionGetForInputCheckJPAExecutor	JPAExecutor to get attributes of CoordinatorActionBean required by CoordActionInputCheckXCommand
CoordActionGetForStartJPAExecutor	JPAExecutor to get attributes of CoordinatorActionBean required by CoordActionStartXCommand
CoordActionGetForTimeoutJPAExecutor	JPAExecutor to get attributes of CoordinatorActionBean required by CoordActionTimeoutXCommand
CoordActionGetJPAExecutor	Load the CoordinatorAction into a Bean and return it.
CoordActionInsertJPAExecutor	Persist the CoordinatorAction bean.
CoordActionRemoveJPAExecutor	Deletes the coordinator action if its in WAITING or READY state.
CoordActionsActiveCountJPAExecutor	Load the number of running actions for a coordinator job.
CoordActionsGetByLastModifiedTimeJPAExecutor	Load the list of CoordinatorAction ordered by lastModifiedTime
CoordActionsGetForRecoveryJPAExecutor
CoordActionsGetReadyGroupbyJobIDJPAExecutor
CoordActionsPendingFalseCountGetJPAExecutor	Load the number of pending actions for a coordinator job.
CoordActionsPendingFalseStatusCountGetJPAExecutor	Load the number of pending actions for a status for a coordinator job.
CoordActionsRunningGetJPAExecutor	Load the list of running CoordinatorAction and return the list.
CoordActionUpdateForInputCheckJPAExecutor	Updates the action status, pending status, last modified time, actionXml and missingDependencies of CoordinatorAction and persists it.
CoordActionUpdateForModifiedTimeJPAExecutor	Updates the last modified time of CoordinatorAction and persists it.
CoordActionUpdateJPAExecutor	Update the CoordinatorAction into a Bean and persist it
CoordActionUpdateStatusJPAExecutor	Updates the action status, pending status and last modified time of CoordinatorAction and persists it.
CoordJobDeleteJPAExecutor	Delete coord job
CoordJobGetActionByActionNumberJPAExecutor	Load the CoordinatorJob into a Bean and return it.
CoordJobGetActionForNominalTimeJPAExecutor	Load coordinator action by nominal time.
CoordJobGetActionIdsForDateRangeJPAExecutor	Load coordinator action ids by date range.
CoordJobGetActionsForDatesJPAExecutor	Load coordinator actions by dates.
CoordJobGetActionsJPAExecutor	Load coordinator actions for a coordinator job.
CoordJobGetActionsNotCompletedJPAExecutor	Load the Coordinator actions which are not completed for a given Coordinator job
CoordJobGetActionsRunningJPAExecutor	Load the running Coordinator actions for a given Coordinator job
CoordJobGetActionsStatusJPAExecutor	Get the status of Coordinator actions for a given Coordinator job
CoordJobGetActionsSubsetJPAExecutor	Load coordinator actions by start and len (a subset) for a coordinator job.
CoordJobGetActionsSuspendedJPAExecutor	Load the suspended Coordinator actions of a given Coordinator job
CoordJobGetJPAExecutor	Load the CoordinatorJob into a Bean and return it.
CoordJobGetPendingActionsCountJPAExecutor	Get the count of pending coordinator actions of a coordinator job
CoordJobGetReadyActionsJPAExecutor	Load coordinator actions in READY state for a coordinator job.
CoordJobGetRunningActionsCountJPAExecutor	Load the number of running actions for a coordinator job.
CoordJobInfoGetJPAExecutor	Load the CoordinatorInfo and return it.
CoordJobInsertJPAExecutor	Persist the CoordinatorJob bean.
CoordJobsGetForPurgeJPAExecutor	Load the list of completed CoordinatorJob for purge ready.
CoordJobsGetPausedJPAExecutor	Get a list of paused bundle Jobs;
CoordJobsGetPendingJPAExecutor	Get a list of Coordinator Jobs that are in pending.
CoordJobsGetUnpausedJPAExecutor	Get a list of unpaused Coordinator Jobs;
CoordJobsToBeMaterializedJPAExecutor	JPA command to get coordinator jobs which are qualify for Materialization.
CoordJobUpdateJPAExecutor	Update the CoordinatorJob into a Bean and persist it.
SLAEventInsertJPAExecutor	Persist the SLAEventBean bean.
SLAEventsGetForFilterJPAExecutor	Load the list of SLAEventBean for a seqId and return the list.
SLAEventsGetForSeqIdJPAExecutor	Load the list of SLAEventBean for a seqId and return the list.
SLAEventsGetJPAExecutor	Load the list of SLAEventBean and return the list.
WorkflowActionDeleteJPAExecutor
WorkflowActionGetJPAExecutor	Load the WorkflowAction into a Bean and return it.
WorkflowActionInsertJPAExecutor	Persist the WorkflowAction bean.
WorkflowActionRetryManualGetJPAExecutor
WorkflowActionsGetForJobJPAExecutor	Load the list of WorkflowAction for a WorkflowJob and return the list.
WorkflowActionsGetPendingJPAExecutor
WorkflowActionsRunningGetJPAExecutor	JPA Executor to get running workflow actions
WorkflowActionSubsetGetJPAExecutor	JPA Command to get subset of workflow actions for a particular workflow.
WorkflowActionUpdateJPAExecutor	Persist the WorkflowAction bean.
WorkflowIdGetForExternalIdJPAExecutor	Get the Workflow ID with given external ID which will be assigned for the subworkflows.
WorkflowInfoWithActionsSubsetGetJPAExecutor	This JPA Executor is responsible for getting the Workflow job with actions in certain range.
WorkflowJobDeleteJPAExecutor	Delete workflow job
WorkflowJobGetActionsJPAExecutor	Load workflow actions for a workflow job.
WorkflowJobGetJPAExecutor	Load the WorkflowJob into a Bean and return it.
WorkflowJobInsertJPAExecutor	Persist the WorkflowJob bean.
WorkflowJobsGetForPurgeJPAExecutor	Load the list of completed WorkflowJob for purge ready.
WorkflowJobUpdateJPAExecutor	Persist the WorkflowJob bean.
WorkflowsJobGetJPAExecutor

Exception Summary

JPAExecutorException

Exception thrown by JPAExecutors.