Class JPAPersistenceManagerService
- java.lang.Object
-
- org.apache.batchee.container.services.persistence.JPAPersistenceManagerService
-
- All Implemented Interfaces:
BatchService,PersistenceManagerService
public class JPAPersistenceManagerService extends Object implements PersistenceManagerService
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.batchee.spi.PersistenceManagerService
PersistenceManagerService.TimestampType
-
-
Constructor Summary
Constructors Constructor Description JPAPersistenceManagerService()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidcleanUp(long instanceId)voidcleanUp(Date until)RuntimeFlowInSplitExecutioncreateFlowInSplitExecution(javax.batch.runtime.JobInstance jobInstance, javax.batch.runtime.BatchStatus batchStatus)RuntimeJobExecutioncreateJobExecution(javax.batch.runtime.JobInstance jobInstance, Properties jobParameters, javax.batch.runtime.BatchStatus batchStatus)Create a JobExecutionjavax.batch.runtime.JobInstancecreateJobInstance(String name, String jobXml)Creates a JobIntanceJobStatuscreateJobStatus(long jobInstanceId)Create a JobStatusStepExecutionImplcreateStepExecution(long jobExecId, StepContextImpl stepContext)Create a StepExecutionStepStatuscreateStepStatus(long stepExecId)Create a StepStatusjavax.batch.runtime.JobInstancecreateSubJobInstance(String name)CheckpointDatagetCheckpointData(CheckpointDataKey key)longgetJobInstanceIdByExecutionId(long executionId)Set<String>getJobNames()JobStatusgetJobStatus(long instanceId)Get a JobStatusJobStatusgetJobStatusFromExecution(long executionId)longgetMostRecentExecutionId(long jobInstanceId)PropertiesgetParameters(long executionId)javax.batch.runtime.StepExecutiongetStepExecutionByStepExecutionId(long stepExecId)List<javax.batch.runtime.StepExecution>getStepExecutionsForJobExecution(long execid)StepStatusgetStepStatus(long instanceId, String stepName)Get a StepStatusvoidinit(Properties batchConfig)InternalJobExecutionjobOperatorGetJobExecution(long jobExecutionId)List<InternalJobExecution>jobOperatorGetJobExecutions(long jobInstanceId)intjobOperatorGetJobInstanceCount(String jobName)JOB OPERATOR ONLY METHODSList<Long>jobOperatorGetJobInstanceIds(String jobName, int start, int count)Set<Long>jobOperatorGetRunningExecutions(String jobName)StringjobOperatorQueryJobExecutionBatchStatus(long key)StringjobOperatorQueryJobExecutionExitStatus(long key)TimestampjobOperatorQueryJobExecutionTimestamp(long key, PersistenceManagerService.TimestampType timetype)voidmarkJobStarted(long key, Timestamp startTS)voidsetCheckpointData(CheckpointDataKey key, CheckpointData value)voidupdateBatchStatusOnly(long executionId, javax.batch.runtime.BatchStatus batchStatus, Timestamp timestamp)voidupdateJobStatus(long instanceId, JobStatus jobStatus)Update a JobStatusvoidupdateStepExecution(long jobExecId, StepContextImpl stepContext)Update a StepExecutionvoidupdateStepStatus(long stepExecutionId, StepStatus stepStatus)Update a StepStatusvoidupdateWithFinalExecutionStatusesAndTimestamps(long key, javax.batch.runtime.BatchStatus batchStatus, String exitStatus, Timestamp updatets)
-
-
-
Method Detail
-
cleanUp
public void cleanUp(long instanceId)
- Specified by:
cleanUpin interfacePersistenceManagerService
-
cleanUp
public void cleanUp(Date until)
- Specified by:
cleanUpin interfacePersistenceManagerService
-
getStepStatus
public StepStatus getStepStatus(long instanceId, String stepName)
Description copied from interface:PersistenceManagerServiceGet a StepStatusThe parent job instance id and this step name from the job xml are used to determine if the current step execution have previously run.
- Specified by:
getStepStatusin interfacePersistenceManagerService- Parameters:
instanceId- the parent job instance idstepName- the step name- Returns:
- the StepStatus
-
getJobNames
public Set<String> getJobNames()
- Specified by:
getJobNamesin interfacePersistenceManagerService
-
getJobStatusFromExecution
public JobStatus getJobStatusFromExecution(long executionId)
- Specified by:
getJobStatusFromExecutionin interfacePersistenceManagerService
-
getStepExecutionByStepExecutionId
public javax.batch.runtime.StepExecution getStepExecutionByStepExecutionId(long stepExecId)
- Specified by:
getStepExecutionByStepExecutionIdin interfacePersistenceManagerService
-
getStepExecutionsForJobExecution
public List<javax.batch.runtime.StepExecution> getStepExecutionsForJobExecution(long execid)
- Specified by:
getStepExecutionsForJobExecutionin interfacePersistenceManagerService
-
updateStepExecution
public void updateStepExecution(long jobExecId, StepContextImpl stepContext)Description copied from interface:PersistenceManagerServiceUpdate a StepExecution- Specified by:
updateStepExecutionin interfacePersistenceManagerService- Parameters:
jobExecId- the parent JobExecution idstepContext- the step context for this step execution
-
createStepExecution
public StepExecutionImpl createStepExecution(long jobExecId, StepContextImpl stepContext)
Description copied from interface:PersistenceManagerServiceCreate a StepExecution- Specified by:
createStepExecutionin interfacePersistenceManagerService- Parameters:
jobExecId- the parent JobExecution idstepContext- the step context for this step execution- Returns:
- the StepExecution
-
getJobInstanceIdByExecutionId
public long getJobInstanceIdByExecutionId(long executionId) throws javax.batch.operations.NoSuchJobExecutionException- Specified by:
getJobInstanceIdByExecutionIdin interfacePersistenceManagerService- Throws:
javax.batch.operations.NoSuchJobExecutionException
-
jobOperatorGetRunningExecutions
public Set<Long> jobOperatorGetRunningExecutions(String jobName)
- Specified by:
jobOperatorGetRunningExecutionsin interfacePersistenceManagerService
-
jobOperatorGetJobExecutions
public List<InternalJobExecution> jobOperatorGetJobExecutions(long jobInstanceId)
- Specified by:
jobOperatorGetJobExecutionsin interfacePersistenceManagerService
-
updateWithFinalExecutionStatusesAndTimestamps
public void updateWithFinalExecutionStatusesAndTimestamps(long key, javax.batch.runtime.BatchStatus batchStatus, String exitStatus, Timestamp updatets)- Specified by:
updateWithFinalExecutionStatusesAndTimestampsin interfacePersistenceManagerService
-
jobOperatorGetJobExecution
public InternalJobExecution jobOperatorGetJobExecution(long jobExecutionId)
- Specified by:
jobOperatorGetJobExecutionin interfacePersistenceManagerService
-
markJobStarted
public void markJobStarted(long key, Timestamp startTS)- Specified by:
markJobStartedin interfacePersistenceManagerService
-
getParameters
public Properties getParameters(long executionId) throws javax.batch.operations.NoSuchJobExecutionException
- Specified by:
getParametersin interfacePersistenceManagerService- Throws:
javax.batch.operations.NoSuchJobExecutionException
-
jobOperatorQueryJobExecutionExitStatus
public String jobOperatorQueryJobExecutionExitStatus(long key)
- Specified by:
jobOperatorQueryJobExecutionExitStatusin interfacePersistenceManagerService
-
jobOperatorQueryJobExecutionBatchStatus
public String jobOperatorQueryJobExecutionBatchStatus(long key)
- Specified by:
jobOperatorQueryJobExecutionBatchStatusin interfacePersistenceManagerService
-
jobOperatorQueryJobExecutionTimestamp
public Timestamp jobOperatorQueryJobExecutionTimestamp(long key, PersistenceManagerService.TimestampType timetype)
- Specified by:
jobOperatorQueryJobExecutionTimestampin interfacePersistenceManagerService
-
createFlowInSplitExecution
public RuntimeFlowInSplitExecution createFlowInSplitExecution(javax.batch.runtime.JobInstance jobInstance, javax.batch.runtime.BatchStatus batchStatus)
- Specified by:
createFlowInSplitExecutionin interfacePersistenceManagerService
-
getMostRecentExecutionId
public long getMostRecentExecutionId(long jobInstanceId)
- Specified by:
getMostRecentExecutionIdin interfacePersistenceManagerService
-
updateBatchStatusOnly
public void updateBatchStatusOnly(long executionId, javax.batch.runtime.BatchStatus batchStatus, Timestamp timestamp)- Specified by:
updateBatchStatusOnlyin interfacePersistenceManagerService
-
createJobExecution
public RuntimeJobExecution createJobExecution(javax.batch.runtime.JobInstance jobInstance, Properties jobParameters, javax.batch.runtime.BatchStatus batchStatus)
Description copied from interface:PersistenceManagerServiceCreate a JobExecution- Specified by:
createJobExecutionin interfacePersistenceManagerService- Parameters:
jobInstance- the parent job instancejobParameters- the parent job instance parametersbatchStatus- the current BatchStatus- Returns:
- the RuntimeJobExecution class for this JobExecution
-
createSubJobInstance
public javax.batch.runtime.JobInstance createSubJobInstance(String name)
- Specified by:
createSubJobInstancein interfacePersistenceManagerService
-
jobOperatorGetJobInstanceIds
public List<Long> jobOperatorGetJobInstanceIds(String jobName, int start, int count)
- Specified by:
jobOperatorGetJobInstanceIdsin interfacePersistenceManagerService
-
createJobInstance
public javax.batch.runtime.JobInstance createJobInstance(String name, String jobXml)
Description copied from interface:PersistenceManagerServiceCreates a JobIntance- Specified by:
createJobInstancein interfacePersistenceManagerService- Parameters:
name- the job id from job.xmljobXml- the resolved job xml- Returns:
- the job instance
-
jobOperatorGetJobInstanceCount
public int jobOperatorGetJobInstanceCount(String jobName)
Description copied from interface:PersistenceManagerServiceJOB OPERATOR ONLY METHODS- Specified by:
jobOperatorGetJobInstanceCountin interfacePersistenceManagerService
-
updateStepStatus
public void updateStepStatus(long stepExecutionId, StepStatus stepStatus)Description copied from interface:PersistenceManagerServiceUpdate a StepStatus- Specified by:
updateStepStatusin interfacePersistenceManagerService- Parameters:
stepExecutionId- the parent step execution idstepStatus- the step status to be updated
-
createStepStatus
public StepStatus createStepStatus(long stepExecId)
Description copied from interface:PersistenceManagerServiceCreate a StepStatus- Specified by:
createStepStatusin interfacePersistenceManagerService- Parameters:
stepExecId- the parent step execution id- Returns:
- the StepStatus
-
updateJobStatus
public void updateJobStatus(long instanceId, JobStatus jobStatus)Description copied from interface:PersistenceManagerServiceUpdate a JobStatus- Specified by:
updateJobStatusin interfacePersistenceManagerService- Parameters:
instanceId- the parent job instance idjobStatus- the job status to be updated
-
getJobStatus
public JobStatus getJobStatus(long instanceId)
Description copied from interface:PersistenceManagerServiceGet a JobStatus- Specified by:
getJobStatusin interfacePersistenceManagerService- Parameters:
instanceId- the parent job instance id- Returns:
- the JobStatus
-
createJobStatus
public JobStatus createJobStatus(long jobInstanceId)
Description copied from interface:PersistenceManagerServiceCreate a JobStatus- Specified by:
createJobStatusin interfacePersistenceManagerService- Parameters:
jobInstanceId- the parent job instance id- Returns:
- the JobStatus
-
setCheckpointData
public void setCheckpointData(CheckpointDataKey key, CheckpointData value)
- Specified by:
setCheckpointDatain interfacePersistenceManagerService
-
getCheckpointData
public CheckpointData getCheckpointData(CheckpointDataKey key)
- Specified by:
getCheckpointDatain interfacePersistenceManagerService
-
init
public void init(Properties batchConfig)
- Specified by:
initin interfaceBatchService
-
-