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, XdJdbcSearchableJobExecutionDao xdJdbcSearchableJobExecutionDao, 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)
int	countTopLevelJobExecutions()
java.util.Collection<org.springframework.batch.core.JobExecution>	getChildJobExecutions(long jobExecutionId) Get a list of all JobExecutions that are direct children to the provided JobExecution ID.
org.springframework.batch.core.Job	getJob(java.lang.String jobName)
java.util.Collection<org.springframework.batch.core.JobExecution>	getTopLevelJobExecutions(int start, int count) Get a list of all JobExecutions that do not have any parent JobExecutions.
boolean	isComposedJobExecution(long jobExecutionId) Determines, if the Job Execution represents a composed job.
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,
                     XdJdbcSearchableJobExecutionDao xdJdbcSearchableJobExecutionDao,
                     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

getTopLevelJobExecutions

public java.util.Collection<org.springframework.batch.core.JobExecution> getTopLevelJobExecutions(int start,
                                                                                         int count)

Get a list of all JobExecutions that do not have any parent JobExecutions.

Parameters:

start -

count -

Returns:

List of JobExecutions. Will never return null.

countTopLevelJobExecutions

public int countTopLevelJobExecutions()

getChildJobExecutions

public java.util.Collection<org.springframework.batch.core.JobExecution> getChildJobExecutions(long jobExecutionId)

Get a list of all JobExecutions that are direct children to the provided JobExecution ID.

Parameters:

jobExecutionId -

Returns:

List of JobExecutions. Will never return null.

isComposedJobExecution

public boolean isComposedJobExecution(long jobExecutionId)

Determines, if the Job Execution represents a composed job.

Parameters:

jobExecutionId -

Returns:

Returns true if the Job Execution represents a composed job.