org.springframework.xd.dirt.plugins.job

Class DistributedJobService

java.lang.Object

org.springframework.batch.admin.service.SimpleJobService

org.springframework.xd.dirt.plugins.job.DistributedJobService

All Implemented Interfaces:

org.springframework.batch.admin.service.JobService, org.springframework.beans.factory.DisposableBean

public class DistributedJobService
extends org.springframework.batch.admin.service.SimpleJobService

SimpleJobService in distributed mode

Author:

Ilayaperumal Gopinathan, Andrew Eisenberg, Gunnar Hillert

Constructor Summary

Constructors

Constructor and Description

DistributedJobService(org.springframework.batch.admin.service.SearchableJobInstanceDao jobInstanceDao, org.springframework.batch.admin.service.SearchableJobExecutionDao jobExecutionDao, org.springframework.batch.admin.service.SearchableStepExecutionDao stepExecutionDao, org.springframework.batch.core.repository.JobRepository jobRepository, org.springframework.batch.core.launch.JobLauncher jobLauncher, DistributedJobLocator batchJobLocator, org.springframework.batch.core.repository.dao.ExecutionContextDao executionContextDao)

Method Summary

Methods

Modifier and Type	Method and Description
org.springframework.batch.core.JobExecution	abandon(java.lang.Long jobExecutionId)
org.springframework.batch.core.Job	getJob(java.lang.String jobName)
boolean	isIncrementable(java.lang.String jobName)
org.springframework.batch.core.JobExecution	launch(java.lang.String jobName, org.springframework.batch.core.JobParameters params)
org.springframework.batch.core.JobExecution	restart(java.lang.Long jobExecutionId)

Methods inherited from class org.springframework.batch.admin.service.SimpleJobService

countJobExecutions, countJobExecutionsForJob, countJobInstances, countJobs, countStepExecutionsForStep, destroy, getJobExecution, getJobExecutionsForJobInstance, getJobInstance, getLastJobParameters, getStepExecution, getStepExecutions, getStepNamesForJob, isLaunchable, listJobExecutions, listJobExecutionsForJob, listJobInstances, listJobs, listStepExecutionsForStep, removeInactiveExecutions, setShutdownTimeout, stop, stopAll

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedJobService

public DistributedJobService(org.springframework.batch.admin.service.SearchableJobInstanceDao jobInstanceDao,
                     org.springframework.batch.admin.service.SearchableJobExecutionDao jobExecutionDao,
                     org.springframework.batch.admin.service.SearchableStepExecutionDao stepExecutionDao,
                     org.springframework.batch.core.repository.JobRepository jobRepository,
                     org.springframework.batch.core.launch.JobLauncher jobLauncher,
                     DistributedJobLocator batchJobLocator,
                     org.springframework.batch.core.repository.dao.ExecutionContextDao executionContextDao)

Method Detail

launch

public org.springframework.batch.core.JobExecution launch(java.lang.String jobName,
                                                 org.springframework.batch.core.JobParameters params)
                                                   throws org.springframework.batch.core.launch.NoSuchJobException,
                                                          org.springframework.batch.core.repository.JobExecutionAlreadyRunningException,
                                                          org.springframework.batch.core.repository.JobRestartException,
                                                          org.springframework.batch.core.repository.JobInstanceAlreadyCompleteException,
                                                          org.springframework.batch.core.JobParametersInvalidException

Specified by:

launch in interface org.springframework.batch.admin.service.JobService

Overrides:

launch in class org.springframework.batch.admin.service.SimpleJobService

Throws:

org.springframework.batch.core.launch.NoSuchJobException

org.springframework.batch.core.repository.JobExecutionAlreadyRunningException

org.springframework.batch.core.repository.JobRestartException

org.springframework.batch.core.repository.JobInstanceAlreadyCompleteException

org.springframework.batch.core.JobParametersInvalidException

restart

public org.springframework.batch.core.JobExecution restart(java.lang.Long jobExecutionId)
                                                    throws org.springframework.batch.core.launch.NoSuchJobExecutionException,
                                                           org.springframework.batch.core.repository.JobExecutionAlreadyRunningException,
                                                           org.springframework.batch.core.repository.JobRestartException,
                                                           org.springframework.batch.core.repository.JobInstanceAlreadyCompleteException,
                                                           org.springframework.batch.core.launch.NoSuchJobException,
                                                           org.springframework.batch.core.JobParametersInvalidException

Specified by:

restart in interface org.springframework.batch.admin.service.JobService

Overrides:

restart in class org.springframework.batch.admin.service.SimpleJobService

Throws:

org.springframework.batch.core.launch.NoSuchJobExecutionException

org.springframework.batch.core.repository.JobExecutionAlreadyRunningException

org.springframework.batch.core.repository.JobRestartException

org.springframework.batch.core.repository.JobInstanceAlreadyCompleteException

org.springframework.batch.core.launch.NoSuchJobException

org.springframework.batch.core.JobParametersInvalidException

abandon

public org.springframework.batch.core.JobExecution abandon(java.lang.Long jobExecutionId)
                                                    throws org.springframework.batch.core.launch.NoSuchJobExecutionException,
                                                           org.springframework.batch.core.repository.JobExecutionAlreadyRunningException

Specified by:

abandon in interface org.springframework.batch.admin.service.JobService

Overrides:

abandon in class org.springframework.batch.admin.service.SimpleJobService

Throws:

org.springframework.batch.core.launch.NoSuchJobExecutionException

org.springframework.batch.core.repository.JobExecutionAlreadyRunningException

isIncrementable

public boolean isIncrementable(java.lang.String jobName)

Specified by:

isIncrementable in interface org.springframework.batch.admin.service.JobService

Overrides:

isIncrementable in class org.springframework.batch.admin.service.SimpleJobService

getJob

public org.springframework.batch.core.Job getJob(java.lang.String jobName)
                                          throws org.springframework.batch.core.launch.NoSuchJobException

Throws:

org.springframework.batch.core.launch.NoSuchJobException