org.jberet.repository

Class AbstractPersistentRepository

java.lang.Object

org.jberet.repository.AbstractRepository

org.jberet.repository.AbstractPersistentRepository

All Implemented Interfaces:

JobRepository

Direct Known Subclasses:

JdbcRepository, MongoRepository

public abstract class AbstractPersistentRepository
extends AbstractRepository
implements JobRepository

Constructor Summary

Constructors

Constructor and Description
AbstractPersistentRepository()

Method Summary

Modifier and Type	Method and Description
JobExecutionImpl	createJobExecution(JobInstanceImpl jobInstance, Properties jobParameters)
JobInstanceImpl	createJobInstance(Job job, String applicationName, ClassLoader classLoader)
StepExecutionImpl	findOriginalStepExecutionForRestart(String stepName, JobExecutionImpl jobExecutionToRestart, ClassLoader classLoader)
JobExecutionImpl	getJobExecution(long jobExecutionId)
JobInstanceImpl	getJobInstance(long jobInstanceId)
List<javax.batch.runtime.StepExecution>	getStepExecutions(long jobExecutionId, ClassLoader classLoader)
void	removeJob(String jobId)
void	removeJobExecutions(JobExecutionSelector jobExecutionSelector) Removes JobExecutions based on the criteria specified in jobExecutionSelector.
void	removeJobInstance(long jobInstanceIdToRemove)

Methods inherited from class org.jberet.repository.AbstractRepository

addJob, addPartitionExecution, addStepExecution, createStepExecution, getJob, getJobNames, getPartitionExecutions, jobExists, savePersistentData, updateJobExecution

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

addJob, addPartitionExecution, addStepExecution, countStepStartTimes, createStepExecution, getJob, getJobExecutions, getJobInstanceCount, getJobInstances, getJobNames, getPartitionExecutions, getRunningExecutions, jobExists, savePersistentData, updateJobExecution, updateStepExecution

Constructor Detail

AbstractPersistentRepository

public AbstractPersistentRepository()

Method Detail

removeJob

public void removeJob(String jobId)

Specified by:

removeJob in interface JobRepository

Overrides:

removeJob in class AbstractRepository

removeJobExecutions

public void removeJobExecutions(JobExecutionSelector jobExecutionSelector)

Description copied from interface: JobRepository

Removes JobExecutions based on the criteria specified in jobExecutionSelector.

Specified by:

removeJobExecutions in interface JobRepository

Parameters:

jobExecutionSelector - criteria for which JobExecutions to remove

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 JobInstanceImpl getJobInstance(long jobInstanceId)

Specified by:

getJobInstance in interface JobRepository

createJobExecution

public JobExecutionImpl createJobExecution(JobInstanceImpl jobInstance,
                                           Properties jobParameters)

Specified by:

createJobExecution in interface JobRepository

getJobExecution

public JobExecutionImpl getJobExecution(long jobExecutionId)

Specified by:

getJobExecution in interface JobRepository

getStepExecutions

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

Specified by:

getStepExecutions in interface JobRepository

findOriginalStepExecutionForRestart

public StepExecutionImpl findOriginalStepExecutionForRestart(String stepName,
                                                             JobExecutionImpl jobExecutionToRestart,
                                                             ClassLoader classLoader)

Specified by:

findOriginalStepExecutionForRestart in interface JobRepository