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 and Description
DataSource	dataSource
org.springframework.batch.core.configuration.annotation.JobBuilderFactory	jobBuilderFactory
org.springframework.batch.core.repository.JobRepository	jobRepository
org.springframework.batch.core.configuration.annotation.StepBuilderFactory	stepBuilderFactory

Constructor Summary

Constructors

Constructor and Description
JobConfiguration()

Method Summary

Modifier and Type	Method and 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.batch.core.Step	step1(org.springframework.batch.core.partition.PartitionHandler partitionHandler)
DeployerStepExecutionHandler	stepExecutionHandler(org.springframework.batch.core.explore.JobExplorer jobExplorer)
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 Detail

jobBuilderFactory

@Autowired
public org.springframework.batch.core.configuration.annotation.JobBuilderFactory jobBuilderFactory

stepBuilderFactory

@Autowired
public org.springframework.batch.core.configuration.annotation.StepBuilderFactory stepBuilderFactory

dataSource

@Autowired
public DataSource dataSource

jobRepository

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

Constructor Detail

JobConfiguration

public JobConfiguration()

Method Detail

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)
                                                                                 throws Exception

Throws:

Exception

partitioner

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

stepExecutionHandler

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

workerTasklet

@Bean
 @StepScope
public org.springframework.batch.core.step.tasklet.Tasklet workerTasklet(@Value(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(value="!worker")
public org.springframework.batch.core.Job partitionedJob(org.springframework.batch.core.partition.PartitionHandler partitionHandler)
                                                                                   throws Exception

Throws:

Exception