Package | Description |
---|---|
org.apache.oozie.executor.jpa | |
org.apache.oozie.executor.jpa.sla | |
org.apache.oozie.service |
Modifier and Type | Class and Description |
---|---|
class |
BulkJPAExecutor
The query executor class for bulk monitoring queries i.e.
|
class |
BundleActionGetJPAExecutor
Load the BundleAction into a Bean and return it.
|
class |
BundleActionInsertJPAExecutor
Persist the BundleAction bean.
|
class |
BundleActionsCountForJobGetJPAExecutor
Load the number of actions for a bundle job.
|
class |
BundleJobGetCoordinatorsJPAExecutor
Load the coordinators for specified bundle in the Coordinator job bean
|
class |
BundleJobGetForUserJPAExecutor
Retrieve the name of the user submitting the bundle job
|
class |
BundleJobGetJPAExecutor
Load the BundleJob into a Bean and return it.
|
class |
BundleJobInfoGetJPAExecutor
Load the BundleInfo and return it.
|
class |
BundleJobInsertJPAExecutor
Persist the BundleJob bean.
|
class |
BundleJobsDeleteJPAExecutor
Delete Bundle job, its list of actions and return the number of actions that were deleted.
|
class |
BundleJobsGetForPurgeJPAExecutor
Load the list of completed BundleJob for purge ready.
|
class |
BundleJobsGetNeedStartJPAExecutor
Get a list of bundle Jobs that need to be started;
|
class |
BundleJobsGetPausedJPAExecutor
Get a list of paused bundle Jobs;
|
class |
BundleJobsGetRunningOrPendingJPAExecutor
Get a list of Bundle Jobs that are are RUNNING or RUNNINGWITHERROR status or the pending flag is 1.
|
class |
BundleJobsGetUnpausedJPAExecutor
Get a list of unpaused bundle Jobs;
|
class |
CoordActionGetForCheckJPAExecutor
JPAExecutor to get attributes of CoordinatorActionBean required by CoordActionCheckCommand
|
class |
CoordActionGetForExternalIdJPAExecutor
Load coordinator action by externalId.
|
class |
CoordActionGetForInfoJPAExecutor
Load the CoordinatorAction into a Bean and return it.
|
class |
CoordActionGetForInputCheckJPAExecutor
JPAExecutor to get attributes of CoordinatorActionBean required by CoordActionInputCheckXCommand
|
class |
CoordActionGetForStartJPAExecutor
JPAExecutor to get attributes of CoordinatorActionBean required by CoordActionStartXCommand
|
class |
CoordActionGetForTimeoutJPAExecutor
JPAExecutor to get attributes of CoordinatorActionBean required by CoordActionTimeoutXCommand
|
class |
CoordActionGetJPAExecutor
Load the CoordinatorAction into a Bean and return it.
|
class |
CoordActionInsertJPAExecutor
Persist the CoordinatorAction bean.
|
class |
CoordActionRemoveJPAExecutor
Deletes the coordinator action if its in WAITING or READY state.
|
class |
CoordActionsActiveCountJPAExecutor
Load the number of running actions for a coordinator job.
|
class |
CoordActionsCountForJobIdJPAExecutor
Load the number of running actions for a coordinator job.
|
class |
CoordActionsDeleteJPAExecutor
Delete Coord actions of long running coordinators, return the number of actions that were deleted.
|
class |
CoordActionsGetFromCoordJobIdJPAExecutor |
class |
CoordActionsPendingFalseCountGetJPAExecutor
Load the number of pending actions for a coordinator job.
|
class |
CoordActionsPendingFalseStatusCountGetJPAExecutor
Load the number of pending actions for a status for a coordinator job.
|
class |
CoordActionsRunningGetJPAExecutor
Load the list of running CoordinatorAction and return the list.
|
class |
CoordinatorJobGetForUserAppnameJPAExecutor
DB query executor to fetch columns 'user' and 'appName' from Coordinator Job table
|
class |
CoordinatorJobGetForUserJPAExecutor
Retrieve the name of user submitting coordinator
|
class |
CoordJobGetActionByActionNumberJPAExecutor
Load the CoordinatorJob into a Bean and return it.
|
class |
CoordJobGetActionForNominalTimeJPAExecutor
Load coordinator action by nominal time.
|
class |
CoordJobGetActionModifiedDateForRangeJPAExecutor |
class |
CoordJobGetActionRunningCountForRangeJPAExecutor |
class |
CoordJobGetActionsJPAExecutor
Load coordinator actions for a coordinator job.
|
class |
CoordJobGetActionsNotCompletedJPAExecutor
Load the Coordinator actions which are not completed for a given Coordinator job
|
class |
CoordJobGetActionsRunningJPAExecutor
Load the running Coordinator actions for a given Coordinator job
|
class |
CoordJobGetActionsStatusJPAExecutor
Get the status of Coordinator actions for a given Coordinator job
|
class |
CoordJobGetActionsSubsetJPAExecutor
Load coordinator actions by offset and len (a subset) for a coordinator job.
|
class |
CoordJobGetActionsSuspendedJPAExecutor
Load the suspended Coordinator actions of a given Coordinator job
|
class |
CoordJobGetJPAExecutor
Load the CoordinatorJob into a Bean and return it.
|
class |
CoordJobGetReadyActionsJPAExecutor
Load coordinator actions in READY state for a coordinator job.
|
class |
CoordJobGetRunningActionsCountJPAExecutor
Load the number of running actions for a coordinator job.
|
class |
CoordJobInfoGetJPAExecutor
Load the CoordinatorInfo and return it.
|
class |
CoordJobInsertJPAExecutor
Persist the CoordinatorJob bean.
|
class |
CoordJobsCountNotForPurgeFromParentIdJPAExecutor
Count the number of Coordinator children of a parent bundle that are not ready to be purged
|
class |
CoordJobsDeleteJPAExecutor
Delete Coord job, its list of actions and return the number of actions that were deleted.
|
class |
CoordJobsGetForPurgeJPAExecutor
Load the list of completed CoordinatorJob for purge ready.
|
class |
CoordJobsGetFromParentIdJPAExecutor
Load the list of CoordinatorJob with the passed in parentId
|
class |
CoordJobsGetPausedJPAExecutor
Get a list of paused bundle Jobs;
|
class |
CoordJobsGetPendingJPAExecutor
Get a list of Coordinator Jobs that are in pending.
|
class |
CoordJobsGetUnpausedJPAExecutor
Get a list of unpaused Coordinator Jobs;
|
class |
CoordJobsToBeMaterializedJPAExecutor
JPA command to get coordinator jobs which are qualify for Materialization.
|
class |
JsonBeanPersisterExecutor |
class |
SLAEventInsertJPAExecutor
Deprecated.
|
class |
SLAEventsGetForFilterJPAExecutor
Deprecated.
|
class |
SLAEventsGetForSeqIdJPAExecutor
Deprecated.
|
class |
SLAEventsGetJPAExecutor
Deprecated.
|
class |
WorkflowActionDeleteJPAExecutor |
class |
WorkflowActionGetJPAExecutor
Load the WorkflowAction into a Bean and return it.
|
class |
WorkflowActionInsertJPAExecutor
Persist the WorkflowAction bean.
|
class |
WorkflowActionRetryManualGetJPAExecutor |
class |
WorkflowActionsGetForJobJPAExecutor
Load the list of WorkflowAction for a WorkflowJob and return the list.
|
class |
WorkflowActionSubsetGetJPAExecutor
JPA Command to get subset of workflow actions for a particular workflow.
|
class |
WorkflowIdGetForExternalIdJPAExecutor
Get the Workflow ID with given external ID which will be assigned for the subworkflows.
|
class |
WorkflowInfoWithActionsSubsetGetJPAExecutor
This JPA Executor is responsible for getting the Workflow job with actions in certain range.
|
class |
WorkflowJobDeleteJPAExecutor
Delete workflow job
|
class |
WorkflowJobGetActionsJPAExecutor
Load workflow actions for a workflow job.
|
class |
WorkflowJobGetForUserJPAExecutor
Retrieve the name of user submitting workflow
|
class |
WorkflowJobGetJPAExecutor
Load the WorkflowJob into a Bean and return it.
|
class |
WorkflowJobInsertJPAExecutor
Persist the WorkflowJob bean.
|
class |
WorkflowJobsBasicInfoFromCoordParentIdJPAExecutor |
class |
WorkflowJobsBasicInfoFromWorkflowParentIdJPAExecutor |
class |
WorkflowJobsDeleteJPAExecutor
Delete WF job, its list of actions and return the number of actions that were deleted.
|
class |
WorkflowJobsGetForPurgeJPAExecutor
Load the list of completed WorkflowJob for purge ready.
|
class |
WorkflowJobsGetFromCoordParentIdJPAExecutor
Load the list of WorkflowJob with the passed in coordinator parentId.
|
class |
WorkflowJobsGetFromWorkflowParentIdJPAExecutor
Load the list of WorkflowJob with the passed in workflow parentId
|
class |
WorkflowsJobGetJPAExecutor |
Modifier and Type | Class and Description |
---|---|
class |
SLASummaryGetForFilterJPAExecutor
Load the list of SLASummaryBean (for dashboard) and return the list.
|
class |
SLASummaryGetRecordsOnRestartJPAExecutor
Load the list of SLASummaryBean when Oozie restarts and return the list.
|
Modifier and Type | Method and Description |
---|---|
<T> T |
JPAService.execute(JPAExecutor<T> executor)
Execute a
JPAExecutor . |
Copyright © 2018 Apache Software Foundation. All rights reserved.