Package io.spring

Class JobConfiguration

java.lang.Object

io.spring.JobConfiguration

@Configuration(proxyBeanMethods=false)
public class JobConfiguration
extends Object

Author:

Michael Minella

Field Summary

Fields

Modifier and Type	Field	Description
DataSource	dataSource
org.springframework.batch.core.repository.JobRepository	jobRepository

Constructor Summary

Constructors

Constructor	Description
JobConfiguration()

Method Summary

Modifier and Type	Method	Description
org.springframework.batch.core.Job	partitionedJob(org.springframework.batch.core.partition.PartitionHandler partitionHandler)
org.springframework.batch.core.partition.support.Partitioner	partitioner()
org.springframework.batch.core.partition.PartitionHandler	partitionHandler(org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher, org.springframework.batch.core.explore.JobExplorer jobExplorer, TaskRepository taskRepository, org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor executor)
org.springframework.batch.core.Step	step1(org.springframework.batch.core.partition.PartitionHandler partitionHandler)
DeployerStepExecutionHandler	stepExecutionHandler(org.springframework.batch.core.explore.JobExplorer jobExplorer)
org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor	threadPoolTaskExecutor()
org.springframework.batch.core.Step	workerStep()
org.springframework.batch.core.step.tasklet.Tasklet	workerTasklet(Integer partitionNumber)

Methods inherited from class java.lang.Object

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

Field Details

jobRepository

@Autowired
public org.springframework.batch.core.repository.JobRepository jobRepository

dataSource

@Autowired
public DataSource dataSource

Constructor Details

JobConfiguration

public JobConfiguration()

Method Details

partitionHandler

@Bean
public org.springframework.batch.core.partition.PartitionHandler partitionHandler(org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher,
 org.springframework.batch.core.explore.JobExplorer jobExplorer,
 TaskRepository taskRepository,
 @Autowired(required=false)
 org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor executor)
                                                                           throws Exception

Throws:

Exception

threadPoolTaskExecutor

@ConditionalOnProperty(value="io.spring.asynchronous",
                       havingValue="true",
                       matchIfMissing=false)
@Bean
public org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor threadPoolTaskExecutor()

partitioner

@Bean
public org.springframework.batch.core.partition.support.Partitioner partitioner()

stepExecutionHandler

@Bean
@Profile("worker")
public DeployerStepExecutionHandler stepExecutionHandler(org.springframework.batch.core.explore.JobExplorer jobExplorer)

workerTasklet

@Bean
@StepScope
public org.springframework.batch.core.step.tasklet.Tasklet workerTasklet(@Value("#{stepExecutionContext[\'partitionNumber\']}")
 Integer partitionNumber)

step1

@Bean
public org.springframework.batch.core.Step step1(org.springframework.batch.core.partition.PartitionHandler partitionHandler)
                                          throws Exception

Throws:

Exception

workerStep

@Bean
public org.springframework.batch.core.Step workerStep()

partitionedJob

@Bean
@Profile("!worker")
public org.springframework.batch.core.Job partitionedJob(org.springframework.batch.core.partition.PartitionHandler partitionHandler)
                                                  throws Exception

Throws:

Exception