public class MemoryPersistenceManagerService extends Object implements PersistenceManagerService
Modifier and Type | Class and Description |
---|---|
protected static interface |
MemoryPersistenceManagerService.Structures |
PersistenceManagerService.TimestampType
Constructor and Description |
---|
MemoryPersistenceManagerService() |
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 rootJobExecId,
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 timestampType) |
void |
markJobStarted(long key,
Timestamp startTS) |
protected org.apache.batchee.container.services.persistence.MemoryPersistenceManagerService.Data |
newData() |
void |
setCheckpointData(CheckpointDataKey key,
CheckpointData value) |
String |
toString() |
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) |
protected org.apache.batchee.container.services.persistence.MemoryPersistenceManagerService.Data newData()
public void init(Properties batchConfig)
init
in interface BatchService
public int jobOperatorGetJobInstanceCount(String jobName)
PersistenceManagerService
jobOperatorGetJobInstanceCount
in interface PersistenceManagerService
public Set<String> getJobNames()
getJobNames
in interface PersistenceManagerService
public List<Long> jobOperatorGetJobInstanceIds(String jobName, int start, int count)
jobOperatorGetJobInstanceIds
in interface PersistenceManagerService
public Timestamp jobOperatorQueryJobExecutionTimestamp(long key, PersistenceManagerService.TimestampType timestampType)
jobOperatorQueryJobExecutionTimestamp
in interface PersistenceManagerService
public String jobOperatorQueryJobExecutionBatchStatus(long key)
jobOperatorQueryJobExecutionBatchStatus
in interface PersistenceManagerService
public String jobOperatorQueryJobExecutionExitStatus(long key)
jobOperatorQueryJobExecutionExitStatus
in interface PersistenceManagerService
public List<javax.batch.runtime.StepExecution> getStepExecutionsForJobExecution(long execid)
getStepExecutionsForJobExecution
in interface PersistenceManagerService
public void updateBatchStatusOnly(long executionId, javax.batch.runtime.BatchStatus batchStatus, Timestamp timestamp)
updateBatchStatusOnly
in interface PersistenceManagerService
public void markJobStarted(long key, Timestamp startTS)
markJobStarted
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 Properties getParameters(long executionId) throws javax.batch.operations.NoSuchJobExecutionException
getParameters
in interface PersistenceManagerService
javax.batch.operations.NoSuchJobExecutionException
public List<InternalJobExecution> jobOperatorGetJobExecutions(long jobInstanceId)
jobOperatorGetJobExecutions
in interface PersistenceManagerService
public Set<Long> jobOperatorGetRunningExecutions(String jobName)
jobOperatorGetRunningExecutions
in interface PersistenceManagerService
public JobStatus getJobStatusFromExecution(long executionId)
getJobStatusFromExecution
in interface PersistenceManagerService
public long getJobInstanceIdByExecutionId(long executionId) throws javax.batch.operations.NoSuchJobExecutionException
getJobInstanceIdByExecutionId
in interface PersistenceManagerService
javax.batch.operations.NoSuchJobExecutionException
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 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 StepExecutionImpl createStepExecution(long rootJobExecId, StepContextImpl stepContext)
PersistenceManagerService
createStepExecution
in interface PersistenceManagerService
rootJobExecId
- the parent JobExecution idstepContext
- the step context for this step executionpublic void updateStepExecution(long jobExecId, StepContextImpl stepContext)
PersistenceManagerService
updateStepExecution
in interface PersistenceManagerService
jobExecId
- the parent JobExecution idstepContext
- the step context for this step executionpublic JobStatus createJobStatus(long jobInstanceId)
PersistenceManagerService
createJobStatus
in interface PersistenceManagerService
jobInstanceId
- the parent job instance idpublic JobStatus getJobStatus(long instanceId)
PersistenceManagerService
getJobStatus
in interface PersistenceManagerService
instanceId
- the parent job instance idpublic void updateJobStatus(long instanceId, JobStatus jobStatus)
PersistenceManagerService
updateJobStatus
in interface PersistenceManagerService
instanceId
- the parent job instance idjobStatus
- the job status to be updatedpublic StepStatus createStepStatus(long stepExecId)
PersistenceManagerService
createStepStatus
in interface PersistenceManagerService
stepExecId
- the parent step execution idpublic 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 void updateStepStatus(long stepExecutionId, StepStatus stepStatus)
PersistenceManagerService
updateStepStatus
in interface PersistenceManagerService
stepExecutionId
- the parent step execution idstepStatus
- the step status to be updatedpublic void setCheckpointData(CheckpointDataKey key, CheckpointData value)
setCheckpointData
in interface PersistenceManagerService
public CheckpointData getCheckpointData(CheckpointDataKey key)
getCheckpointData
in interface PersistenceManagerService
public long getMostRecentExecutionId(long jobInstanceId)
getMostRecentExecutionId
in interface PersistenceManagerService
public javax.batch.runtime.JobInstance createSubJobInstance(String name)
createSubJobInstance
in interface PersistenceManagerService
public RuntimeFlowInSplitExecution createFlowInSplitExecution(javax.batch.runtime.JobInstance jobInstance, javax.batch.runtime.BatchStatus batchStatus)
createFlowInSplitExecution
in interface PersistenceManagerService
public javax.batch.runtime.StepExecution getStepExecutionByStepExecutionId(long stepExecId)
getStepExecutionByStepExecutionId
in interface PersistenceManagerService
public void cleanUp(long instanceId)
cleanUp
in interface PersistenceManagerService
public void cleanUp(Date until)
cleanUp
in interface PersistenceManagerService
Copyright © 2017 The Apache Software Foundation. All rights reserved.