org.jberet.repository

Interface JobRepository

All Known Implementing Classes:

AbstractPersistentRepository, AbstractRepository, InfinispanRepository, InMemoryRepository, JdbcRepository, MongoRepository

public interface JobRepository

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)
int	countStepStartTimes(String stepName, long jobInstanceId)
JobExecutionImpl	createJobExecution(JobInstanceImpl jobInstance, Properties jobParameters)
JobInstanceImpl	createJobInstance(Job job, String applicationName, ClassLoader classLoader)
StepExecutionImpl	createStepExecution(String stepName)
StepExecutionImpl	findOriginalStepExecutionForRestart(String stepName, JobExecutionImpl jobExecutionToRestart, ClassLoader classLoader)
Job	getJob(ApplicationAndJobName applicationAndJobName)
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)
Set<String>	getJobNames() Gets all the job names from the job repository.
List<PartitionExecutionImpl>	getPartitionExecutions(long stepExecutionId, StepExecutionImpl stepExecution, boolean notCompletedOnly, ClassLoader classLoader)
List<Long>	getRunningExecutions(String jobName) Gets the ids of running job executions belonging to a specific job.
List<javax.batch.runtime.StepExecution>	getStepExecutions(long jobExecutionId, ClassLoader classLoader)
boolean	jobExists(String jobName) Checks if a job with the specified jobName exists or not.
void	removeJob(String jobId)
void	removeJobExecutions(JobExecutionSelector jobExecutionSelector) Removes JobExecutions based on the criteria specified in jobExecutionSelector.
void	removeJobInstance(long jobInstanceId)
void	savePersistentData(javax.batch.runtime.JobExecution jobExecution, AbstractStepExecution stepOrPartitionExecution)
void	updateJobExecution(JobExecutionImpl jobExecution, boolean fullUpdate, boolean saveJobParameters)
void	updateStepExecution(javax.batch.runtime.StepExecution stepExecution)

Method Detail

addJob

void addJob(ApplicationAndJobName applicationAndJobName,
            Job job)

removeJob

void removeJob(String jobId)

getJob

Job getJob(ApplicationAndJobName applicationAndJobName)

getJobNames

Set<String> getJobNames()

Gets all the job names from the job repository.

Returns:

a set of job names

Since:

1.1.0.Final

jobExists

boolean jobExists(String jobName)

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

Parameters:

jobName - the job name to check

Returns:

true if the named job exists; false otherwise

Since:

1.1.0.Final

createJobInstance

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

removeJobInstance

void removeJobInstance(long jobInstanceId)

getJobInstance

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

getJobInstances

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

getJobInstanceCount

int getJobInstanceCount(String jobName)

createJobExecution

JobExecutionImpl createJobExecution(JobInstanceImpl jobInstance,
                                    Properties jobParameters)

getJobExecution

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

getJobExecutions

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

updateJobExecution

void updateJobExecution(JobExecutionImpl jobExecution,
                        boolean fullUpdate,
                        boolean saveJobParameters)

getRunningExecutions

List<Long> getRunningExecutions(String jobName)

Gets the ids of running job executions belonging to a specific job.

Parameters:

jobName - the name of the job, not null

Returns:

a list of job execution ids

Since:

1.1.0.Final

See Also:

JobOperatorImpl.getRunningExecutions(java.lang.String)

removeJobExecutions

void removeJobExecutions(JobExecutionSelector jobExecutionSelector)

Removes JobExecutions based on the criteria specified in jobExecutionSelector.

Parameters:

jobExecutionSelector - criteria for which JobExecutions to remove

Since:

1.1.0.Beta1

getStepExecutions

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

createStepExecution

StepExecutionImpl createStepExecution(String stepName)

addStepExecution

void addStepExecution(JobExecutionImpl jobExecution,
                      StepExecutionImpl stepExecution)

updateStepExecution

void updateStepExecution(javax.batch.runtime.StepExecution stepExecution)

findOriginalStepExecutionForRestart

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

countStepStartTimes

int countStepStartTimes(String stepName,
                        long jobInstanceId)

addPartitionExecution

void addPartitionExecution(StepExecutionImpl enclosingStepExecution,
                           PartitionExecutionImpl partitionExecution)

getPartitionExecutions

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

savePersistentData

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