org.jberet.repository

Class AbstractRepository

java.lang.Object

org.jberet.repository.AbstractRepository

All Implemented Interfaces:

JobRepository

Direct Known Subclasses:

AbstractPersistentRepository, InfinispanRepository, InMemoryRepository

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(ApplicationAndJobName applicationAndJobName, Job job)
void	addPartitionExecution(StepExecutionImpl enclosingStepExecution, PartitionExecutionImpl partitionExecution)
void	addStepExecution(JobExecutionImpl jobExecution, StepExecutionImpl stepExecution)
StepExecutionImpl	createStepExecution(String stepName)
Job	getJob(ApplicationAndJobName applicationAndJobName)
Set<String>	getJobNames() Gets all the job names from the job repository.
List<PartitionExecutionImpl>	getPartitionExecutions(long stepExecutionId, StepExecutionImpl stepExecution, boolean notCompletedOnly, ClassLoader classLoader)
boolean	jobExists(String jobName) Checks if a job with the specified jobName exists or not.
void	removeJob(String jobId)
void	savePersistentData(javax.batch.runtime.JobExecution jobExecution, AbstractStepExecution stepOrPartitionExecution)
void	updateJobExecution(JobExecutionImpl jobExecution, boolean fullUpdate, boolean saveJobParameters)

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, createJobExecution, createJobInstance, findOriginalStepExecutionForRestart, getJobExecution, getJobExecutions, getJobInstance, getJobInstanceCount, getJobInstances, getRunningExecutions, getStepExecutions, removeJobExecutions, removeJobInstance, updateStepExecution

Constructor Detail

AbstractRepository

public AbstractRepository()

Method Detail

addJob

public void addJob(ApplicationAndJobName applicationAndJobName,
                   Job job)

Specified by:

addJob in interface JobRepository

getJob

public Job getJob(ApplicationAndJobName applicationAndJobName)

Specified by:

getJob in interface JobRepository

jobExists

public boolean jobExists(String jobName)

Description copied from interface: JobRepository

Checks if a job with the specified jobName exists or not.

Specified by:

jobExists in interface JobRepository

Parameters:

jobName - the job name to check

Returns:

true if the named job exists; false otherwise

getJobNames

public Set<String> getJobNames()

Description copied from interface: JobRepository

Gets all the job names from the job repository.

Specified by:

getJobNames in interface JobRepository

Returns:

a set of job names

removeJob

public void removeJob(String jobId)

Specified by:

removeJob in interface JobRepository

createStepExecution

public StepExecutionImpl createStepExecution(String stepName)

Specified by:

createStepExecution 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(JobExecutionImpl jobExecution,
                               boolean fullUpdate,
                               boolean saveJobParameters)

Specified by:

updateJobExecution 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,
                                                           ClassLoader classLoader)

Specified by:

getPartitionExecutions in interface JobRepository