public class JPAPersistenceManagerService extends Object implements PersistenceManagerService
PersistenceManagerService.TimestampType
Constructor and Description |
---|
JPAPersistenceManagerService() |
Modifier and Type | Method and Description |
---|---|
void |
cleanUp(Date until) |
void |
cleanUp(long instanceId) |
RuntimeFlowInSplitExecution |
createFlowInSplitExecution(javax.batch.runtime.JobInstance jobInstance,
javax.batch.runtime.BatchStatus batchStatus) |
RuntimeJobExecution |
createJobExecution(javax.batch.runtime.JobInstance jobInstance,
Properties jobParameters,
javax.batch.runtime.BatchStatus batchStatus)
Create a JobExecution
|
javax.batch.runtime.JobInstance |
createJobInstance(String name,
String jobXml)
Creates a JobIntance
|
JobStatus |
createJobStatus(long jobInstanceId)
Create a JobStatus
|
StepExecutionImpl |
createStepExecution(long jobExecId,
StepContextImpl stepContext)
Create a StepExecution
|
StepStatus |
createStepStatus(long stepExecId)
Create a StepStatus
|
javax.batch.runtime.JobInstance |
createSubJobInstance(String name) |
CheckpointData |
getCheckpointData(CheckpointDataKey key) |
long |
getJobInstanceIdByExecutionId(long executionId) |
Set<String> |
getJobNames() |
JobStatus |
getJobStatus(long instanceId)
Get a JobStatus
|
JobStatus |
getJobStatusFromExecution(long executionId) |
long |
getMostRecentExecutionId(long jobInstanceId) |
Properties |
getParameters(long executionId) |
javax.batch.runtime.StepExecution |
getStepExecutionByStepExecutionId(long stepExecId) |
List<javax.batch.runtime.StepExecution> |
getStepExecutionsForJobExecution(long execid) |
StepStatus |
getStepStatus(long instanceId,
String stepName)
Get a StepStatus
The parent job instance id and this step name from the job xml
are used to determine if the current step execution have previously run.
|
void |
init(Properties batchConfig) |
InternalJobExecution |
jobOperatorGetJobExecution(long jobExecutionId) |
List<InternalJobExecution> |
jobOperatorGetJobExecutions(long jobInstanceId) |
int |
jobOperatorGetJobInstanceCount(String jobName)
JOB OPERATOR ONLY METHODS
|
List<Long> |
jobOperatorGetJobInstanceIds(String jobName,
int start,
int count) |
Set<Long> |
jobOperatorGetRunningExecutions(String jobName) |
String |
jobOperatorQueryJobExecutionBatchStatus(long key) |
String |
jobOperatorQueryJobExecutionExitStatus(long key) |
Timestamp |
jobOperatorQueryJobExecutionTimestamp(long key,
PersistenceManagerService.TimestampType timetype) |
void |
markJobStarted(long key,
Timestamp startTS) |
void |
setCheckpointData(CheckpointDataKey key,
CheckpointData value) |
void |
updateBatchStatusOnly(long executionId,
javax.batch.runtime.BatchStatus batchStatus,
Timestamp timestamp) |
void |
updateJobStatus(long instanceId,
JobStatus jobStatus)
Update a JobStatus
|
void |
updateStepExecution(long jobExecId,
StepContextImpl stepContext)
Update a StepExecution
|
void |
updateStepStatus(long stepExecutionId,
StepStatus stepStatus)
Update a StepStatus
|
void |
updateWithFinalExecutionStatusesAndTimestamps(long key,
javax.batch.runtime.BatchStatus batchStatus,
String exitStatus,
Timestamp updatets) |
public void cleanUp(long instanceId)
cleanUp
in interface PersistenceManagerService
public void cleanUp(Date until)
cleanUp
in interface PersistenceManagerService
public StepStatus getStepStatus(long instanceId, String stepName)
PersistenceManagerService
The parent job instance id and this step name from the job xml are used to determine if the current step execution have previously run.
getStepStatus
in interface PersistenceManagerService
instanceId
- the parent job instance idstepName
- the step namepublic Set<String> getJobNames()
getJobNames
in interface PersistenceManagerService
public JobStatus getJobStatusFromExecution(long executionId)
getJobStatusFromExecution
in interface PersistenceManagerService
public javax.batch.runtime.StepExecution getStepExecutionByStepExecutionId(long stepExecId)
getStepExecutionByStepExecutionId
in interface PersistenceManagerService
public List<javax.batch.runtime.StepExecution> getStepExecutionsForJobExecution(long execid)
getStepExecutionsForJobExecution
in interface PersistenceManagerService
public void updateStepExecution(long jobExecId, StepContextImpl stepContext)
PersistenceManagerService
updateStepExecution
in interface PersistenceManagerService
jobExecId
- the parent JobExecution idstepContext
- the step context for this step executionpublic StepExecutionImpl createStepExecution(long jobExecId, StepContextImpl stepContext)
PersistenceManagerService
createStepExecution
in interface PersistenceManagerService
jobExecId
- the parent JobExecution idstepContext
- the step context for this step executionpublic long getJobInstanceIdByExecutionId(long executionId) throws javax.batch.operations.NoSuchJobExecutionException
getJobInstanceIdByExecutionId
in interface PersistenceManagerService
javax.batch.operations.NoSuchJobExecutionException
public Set<Long> jobOperatorGetRunningExecutions(String jobName)
jobOperatorGetRunningExecutions
in interface PersistenceManagerService
public List<InternalJobExecution> jobOperatorGetJobExecutions(long jobInstanceId)
jobOperatorGetJobExecutions
in interface PersistenceManagerService
public void updateWithFinalExecutionStatusesAndTimestamps(long key, javax.batch.runtime.BatchStatus batchStatus, String exitStatus, Timestamp updatets)
updateWithFinalExecutionStatusesAndTimestamps
in interface PersistenceManagerService
public InternalJobExecution jobOperatorGetJobExecution(long jobExecutionId)
jobOperatorGetJobExecution
in interface PersistenceManagerService
public void markJobStarted(long key, Timestamp startTS)
markJobStarted
in interface PersistenceManagerService
public Properties getParameters(long executionId) throws javax.batch.operations.NoSuchJobExecutionException
getParameters
in interface PersistenceManagerService
javax.batch.operations.NoSuchJobExecutionException
public String jobOperatorQueryJobExecutionExitStatus(long key)
jobOperatorQueryJobExecutionExitStatus
in interface PersistenceManagerService
public String jobOperatorQueryJobExecutionBatchStatus(long key)
jobOperatorQueryJobExecutionBatchStatus
in interface PersistenceManagerService
public Timestamp jobOperatorQueryJobExecutionTimestamp(long key, PersistenceManagerService.TimestampType timetype)
jobOperatorQueryJobExecutionTimestamp
in interface PersistenceManagerService
public RuntimeFlowInSplitExecution createFlowInSplitExecution(javax.batch.runtime.JobInstance jobInstance, javax.batch.runtime.BatchStatus batchStatus)
createFlowInSplitExecution
in interface PersistenceManagerService
public long getMostRecentExecutionId(long jobInstanceId)
getMostRecentExecutionId
in interface PersistenceManagerService
public void updateBatchStatusOnly(long executionId, javax.batch.runtime.BatchStatus batchStatus, Timestamp timestamp)
updateBatchStatusOnly
in interface PersistenceManagerService
public RuntimeJobExecution createJobExecution(javax.batch.runtime.JobInstance jobInstance, Properties jobParameters, javax.batch.runtime.BatchStatus batchStatus)
PersistenceManagerService
createJobExecution
in interface PersistenceManagerService
jobInstance
- the parent job instancejobParameters
- the parent job instance parametersbatchStatus
- the current BatchStatuspublic javax.batch.runtime.JobInstance createSubJobInstance(String name)
createSubJobInstance
in interface PersistenceManagerService
public List<Long> jobOperatorGetJobInstanceIds(String jobName, int start, int count)
jobOperatorGetJobInstanceIds
in interface PersistenceManagerService
public javax.batch.runtime.JobInstance createJobInstance(String name, String jobXml)
PersistenceManagerService
createJobInstance
in interface PersistenceManagerService
name
- the job id from job.xmljobXml
- the resolved job xmlpublic int jobOperatorGetJobInstanceCount(String jobName)
PersistenceManagerService
jobOperatorGetJobInstanceCount
in interface PersistenceManagerService
public void updateStepStatus(long stepExecutionId, StepStatus stepStatus)
PersistenceManagerService
updateStepStatus
in interface PersistenceManagerService
stepExecutionId
- the parent step execution idstepStatus
- the step status to be updatedpublic StepStatus createStepStatus(long stepExecId)
PersistenceManagerService
createStepStatus
in interface PersistenceManagerService
stepExecId
- the parent step execution idpublic void updateJobStatus(long instanceId, JobStatus jobStatus)
PersistenceManagerService
updateJobStatus
in interface PersistenceManagerService
instanceId
- the parent job instance idjobStatus
- the job status to be updatedpublic JobStatus getJobStatus(long instanceId)
PersistenceManagerService
getJobStatus
in interface PersistenceManagerService
instanceId
- the parent job instance idpublic JobStatus createJobStatus(long jobInstanceId)
PersistenceManagerService
createJobStatus
in interface PersistenceManagerService
jobInstanceId
- the parent job instance idpublic void setCheckpointData(CheckpointDataKey key, CheckpointData value)
setCheckpointData
in interface PersistenceManagerService
public CheckpointData getCheckpointData(CheckpointDataKey key)
getCheckpointData
in interface PersistenceManagerService
public void init(Properties batchConfig)
init
in interface BatchService
Copyright © 2017 The Apache Software Foundation. All rights reserved.