This project has retired. For details please refer to its Attic page.

Package org.apache.oozie.executor.jpa

Interface Summary

JPAExecutor<T>

Executor pattern interface that gives access to an EntityManager.

Class Summary

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
BundleJobGetForUserJPAExecutor	Retrieve the name of the user submitting the bundle job
BundleJobGetJPAExecutor	Load the BundleJob into a Bean and return it.
BundleJobInfoGetJPAExecutor	Load the BundleInfo and return it.
BundleJobInsertJPAExecutor	Persist the BundleJob bean.
BundleJobsDeleteJPAExecutor	Delete Bundle job, its list of actions and return the number of actions that were deleted.
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
CoordActionGetForSLAJPAExecutor	JPAExecutor to get attributes of CoordinatorActionBean required by SLAService on restart
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.
CoordActionsCountForJobIdJPAExecutor	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
CoordActionUpdatePushInputCheckJPAExecutor	Updates the action status, pending status, last modified time, push missingDependencies of CoordinatorAction and persists it.
CoordActionUpdateStatusJPAExecutor	Updates the action status, pending status and last modified time of CoordinatorAction and persists it.
CoordinatorJobGetForUserAppnameJPAExecutor	DB query executor to fetch columns 'user' and 'appName' from Coordinator Job table
CoordinatorJobGetForUserJPAExecutor	Retrieve the name of user submitting coordinator
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.
CoordJobsCountNotForPurgeFromParentIdJPAExecutor	Count the number of Coordinator children of a parent bundle that are not ready to be purged
CoordJobsDeleteJPAExecutor	Delete Coord job, its list of actions and return the number of actions that were deleted.
CoordJobsGetForPurgeJPAExecutor	Load the list of completed CoordinatorJob for purge ready.
CoordJobsGetFromParentIdJPAExecutor	Load the list of CoordinatorJob with the passed in parentId
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	Deprecated.
SLAEventsGetForFilterJPAExecutor	Deprecated.
SLAEventsGetForSeqIdJPAExecutor	Deprecated.
SLAEventsGetJPAExecutor	Deprecated.
WorkflowActionDeleteJPAExecutor
WorkflowActionGetForSLAJPAExecutor	Retrieve the workflow action bean for sla service
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.
WorkflowJobGetForSLAJPAExecutor	Retrieve the workflow job bean for sla service
WorkflowJobGetForUserJPAExecutor	Retrieve the name of user submitting workflow
WorkflowJobGetJPAExecutor	Load the WorkflowJob into a Bean and return it.
WorkflowJobInsertJPAExecutor	Persist the WorkflowJob bean.
WorkflowJobsCountNotForPurgeFromParentIdJPAExecutor	Count the number of Workflow children of a parent Workflow or Coordinator that are not ready to be purged
WorkflowJobsDeleteJPAExecutor	Delete WF job, its list of actions and return the number of actions that were deleted.
WorkflowJobsGetForPurgeJPAExecutor	Load the list of completed WorkflowJob for purge ready.
WorkflowJobsGetFromParentIdJPAExecutor	Load the list of WorkflowJob with the passed in parentId
WorkflowJobUpdateJPAExecutor	Persist the WorkflowJob bean.
WorkflowsJobGetJPAExecutor

Exception Summary

JPAExecutorException

Exception thrown by JPAExecutors.