org.jberet.repository

Class AbstractRepository

java.lang.Object

org.jberet.repository.AbstractRepository

All Implemented Interfaces:

JobRepository

Direct Known Subclasses:

InMemoryRepository, JdbcRepository

public abstract class AbstractRepository
extends Object
implements JobRepository

Constructor Summary

Constructors

Constructor and Description
AbstractRepository()

Method Summary

Modifier and Type	Method and Description
void	addJob(Job job)
void	addPartitionExecution(StepExecutionImpl enclosingStepExecution, PartitionExecutionImpl partitionExecution)
void	addStepExecution(JobExecutionImpl jobExecution, StepExecutionImpl stepExecution)
JobExecutionImpl	createJobExecution(JobInstanceImpl jobInstance, Properties jobParameters)
JobInstanceImpl	createJobInstance(Job job, String applicationName, ClassLoader classLoader)
StepExecutionImpl	createStepExecution(String stepName)
StepExecutionImpl	findOriginalStepExecutionForRestart(String stepName, JobExecutionImpl jobExecutionToRestart)
Job	getJob(String jobId)
javax.batch.runtime.JobExecution	getJobExecution(long jobExecutionId)
List<javax.batch.runtime.JobExecution>	getJobExecutions(javax.batch.runtime.JobInstance jobInstance)
javax.batch.runtime.JobInstance	getJobInstance(long jobInstanceId)
int	getJobInstanceCount(String jobName)
List<javax.batch.runtime.JobInstance>	getJobInstances(String jobName)
Collection<Job>	getJobs()
List<PartitionExecutionImpl>	getPartitionExecutions(long stepExecutionId, StepExecutionImpl stepExecution, boolean notCompletedOnly)
List<javax.batch.runtime.StepExecution>	getStepExecutions(long jobExecutionId)
void	removeJob(String jobId)
void	removeJobInstance(long jobInstanceIdToRemove)
void	savePersistentData(javax.batch.runtime.JobExecution jobExecution, AbstractStepExecution stepOrPartitionExecution)
void	updateJobExecution(javax.batch.runtime.JobExecution jobExecution)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.jberet.repository.JobRepository

countStepStartTimes, updateStepExecution

Constructor Detail

AbstractRepository

public AbstractRepository()

Method Detail

addJob

public void addJob(Job job)

Specified by:

addJob in interface JobRepository

removeJob

public void removeJob(String jobId)

Specified by:

removeJob in interface JobRepository

getJob

public Job getJob(String jobId)

Specified by:

getJob in interface JobRepository

getJobs

public Collection<Job> getJobs()

Specified by:

getJobs in interface JobRepository

createJobInstance

public JobInstanceImpl createJobInstance(Job job,
                                         String applicationName,
                                         ClassLoader classLoader)

Specified by:

createJobInstance in interface JobRepository

removeJobInstance

public void removeJobInstance(long jobInstanceIdToRemove)

Specified by:

removeJobInstance in interface JobRepository

getJobInstance

public javax.batch.runtime.JobInstance getJobInstance(long jobInstanceId)

Specified by:

getJobInstance in interface JobRepository

getJobInstances

public List<javax.batch.runtime.JobInstance> getJobInstances(String jobName)

Specified by:

getJobInstances in interface JobRepository

getJobInstanceCount

public int getJobInstanceCount(String jobName)

Specified by:

getJobInstanceCount in interface JobRepository

createJobExecution

public JobExecutionImpl createJobExecution(JobInstanceImpl jobInstance,
                                           Properties jobParameters)

Specified by:

createJobExecution in interface JobRepository

getJobExecution

public javax.batch.runtime.JobExecution getJobExecution(long jobExecutionId)

Specified by:

getJobExecution in interface JobRepository

getJobExecutions

public List<javax.batch.runtime.JobExecution> getJobExecutions(javax.batch.runtime.JobInstance jobInstance)

Specified by:

getJobExecutions in interface JobRepository

createStepExecution

public StepExecutionImpl createStepExecution(String stepName)

Specified by:

createStepExecution in interface JobRepository

getStepExecutions

public List<javax.batch.runtime.StepExecution> getStepExecutions(long jobExecutionId)

Specified by:

getStepExecutions in interface JobRepository

addStepExecution

public void addStepExecution(JobExecutionImpl jobExecution,
                             StepExecutionImpl stepExecution)

Specified by:

addStepExecution in interface JobRepository

savePersistentData

public void savePersistentData(javax.batch.runtime.JobExecution jobExecution,
                               AbstractStepExecution stepOrPartitionExecution)

Specified by:

savePersistentData in interface JobRepository

updateJobExecution

public void updateJobExecution(javax.batch.runtime.JobExecution jobExecution)

Specified by:

updateJobExecution in interface JobRepository

findOriginalStepExecutionForRestart

public StepExecutionImpl findOriginalStepExecutionForRestart(String stepName,
                                                             JobExecutionImpl jobExecutionToRestart)

Specified by:

findOriginalStepExecutionForRestart in interface JobRepository

addPartitionExecution

public void addPartitionExecution(StepExecutionImpl enclosingStepExecution,
                                  PartitionExecutionImpl partitionExecution)

Specified by:

addPartitionExecution in interface JobRepository

getPartitionExecutions

public List<PartitionExecutionImpl> getPartitionExecutions(long stepExecutionId,
                                                           StepExecutionImpl stepExecution,
                                                           boolean notCompletedOnly)

Specified by:

getPartitionExecutions in interface JobRepository