org.apache.oozie.executor.jpa

Interface JPAExecutor<T>

All Known Implementing Classes:

BulkJPAExecutor, BundleActionGetJPAExecutor, BundleActionInsertJPAExecutor, BundleActionsCountForJobGetJPAExecutor, BundleJobGetCoordinatorsJPAExecutor, BundleJobGetForUserJPAExecutor, BundleJobGetJPAExecutor, BundleJobInfoGetJPAExecutor, BundleJobInsertJPAExecutor, BundleJobsDeleteJPAExecutor, BundleJobsGetForPurgeJPAExecutor, BundleJobsGetNeedStartJPAExecutor, BundleJobsGetPausedJPAExecutor, BundleJobsGetRunningOrPendingJPAExecutor, BundleJobsGetUnpausedJPAExecutor, CoordActionGetForCheckJPAExecutor, CoordActionGetForExternalIdJPAExecutor, CoordActionGetForInfoJPAExecutor, CoordActionGetForInputCheckJPAExecutor, CoordActionGetForStartJPAExecutor, CoordActionGetForTimeoutJPAExecutor, CoordActionGetJPAExecutor, CoordActionInsertJPAExecutor, CoordActionRemoveJPAExecutor, CoordActionsActiveCountJPAExecutor, CoordActionsCountForJobIdJPAExecutor, CoordActionsDeleteJPAExecutor, CoordActionsGetFromCoordJobIdJPAExecutor, CoordActionsPendingFalseCountGetJPAExecutor, CoordActionsPendingFalseStatusCountGetJPAExecutor, CoordActionsRunningGetJPAExecutor, CoordinatorJobGetForUserAppnameJPAExecutor, CoordinatorJobGetForUserJPAExecutor, CoordJobDeleteJPAExecutor, CoordJobGetActionByActionNumberJPAExecutor, CoordJobGetActionForNominalTimeJPAExecutor, CoordJobGetActionModifiedDateForRangeJPAExecutor, CoordJobGetActionRunningCountForRangeJPAExecutor, CoordJobGetActionsJPAExecutor, CoordJobGetActionsNotCompletedJPAExecutor, CoordJobGetActionsRunningJPAExecutor, CoordJobGetActionsStatusJPAExecutor, CoordJobGetActionsSubsetJPAExecutor, CoordJobGetActionsSuspendedJPAExecutor, CoordJobGetJPAExecutor, CoordJobGetReadyActionsJPAExecutor, CoordJobGetRunningActionsCountJPAExecutor, CoordJobInfoGetJPAExecutor, CoordJobInsertJPAExecutor, CoordJobsCountNotForPurgeFromParentIdJPAExecutor, CoordJobsDeleteJPAExecutor, CoordJobsGetForPurgeJPAExecutor, CoordJobsGetFromParentIdJPAExecutor, CoordJobsGetPausedJPAExecutor, CoordJobsGetPendingJPAExecutor, CoordJobsGetUnpausedJPAExecutor, CoordJobsToBeMaterializedJPAExecutor, SLAEventInsertJPAExecutor, SLAEventsGetForFilterJPAExecutor, SLAEventsGetForSeqIdJPAExecutor, SLAEventsGetJPAExecutor, SLASummaryGetForFilterJPAExecutor, SLASummaryGetRecordsOnRestartJPAExecutor, WorkflowActionDeleteJPAExecutor, WorkflowActionGetJPAExecutor, WorkflowActionInsertJPAExecutor, WorkflowActionRetryManualGetJPAExecutor, WorkflowActionsGetForJobJPAExecutor, WorkflowActionSubsetGetJPAExecutor, WorkflowIdGetForExternalIdJPAExecutor, WorkflowInfoWithActionsSubsetGetJPAExecutor, WorkflowJobDeleteJPAExecutor, WorkflowJobGetActionsJPAExecutor, WorkflowJobGetForUserJPAExecutor, WorkflowJobGetJPAExecutor, WorkflowJobInsertJPAExecutor, WorkflowJobsBasicInfoFromCoordParentIdJPAExecutor, WorkflowJobsBasicInfoFromWorkflowParentIdJPAExecutor, WorkflowJobsDeleteJPAExecutor, WorkflowJobsGetForPurgeJPAExecutor, WorkflowJobsGetFromCoordParentIdJPAExecutor, WorkflowJobsGetFromWorkflowParentIdJPAExecutor, WorkflowsJobGetJPAExecutor

public interface JPAExecutor<T>

Executor pattern interface that gives access to an EntityManager.

Implementations are executed by the JPAService.

Method Summary

Methods

Modifier and Type	Method and Description
T	execute(javax.persistence.EntityManager em) Method that encapsulates JPA access operations.
String	getName() Return the name of the JPA executor.

Method Detail

getName

String getName()

Return the name of the JPA executor. Used for logging and instrumentation.

Returns:

the name of the JPA executor.

execute

T execute(javax.persistence.EntityManager em)
          throws JPAExecutorException

Method that encapsulates JPA access operations.

Implementations should not close the received EntityManager.

Implementations should commit any transaction before ending, else the transaction will be rolled back.

Parameters:

em - an active EntityManager

Returns:

a return value if any.

Throws:

JPAExecutorException - thrown if a jpa executor failed