@Configuration public class JobConfiguration extends Object
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 and Description |
---|
JobConfiguration() |
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) |
@Autowired public org.springframework.batch.core.configuration.annotation.JobBuilderFactory jobBuilderFactory
@Autowired public org.springframework.batch.core.configuration.annotation.StepBuilderFactory stepBuilderFactory
@Autowired public DataSource dataSource
@Autowired public org.springframework.batch.core.repository.JobRepository jobRepository
@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
Exception
@Bean public org.springframework.batch.core.partition.support.Partitioner partitioner()
@Bean @Profile(value="worker") public DeployerStepExecutionHandler stepExecutionHandler(org.springframework.batch.core.explore.JobExplorer jobExplorer)
@Bean @StepScope public org.springframework.batch.core.step.tasklet.Tasklet workerTasklet(@Value(value="#{stepExecutionContext[\'partitionNumber\']}") Integer partitionNumber)
@Bean public org.springframework.batch.core.Step step1(org.springframework.batch.core.partition.PartitionHandler partitionHandler) throws Exception
Exception
@Bean public org.springframework.batch.core.Step workerStep()
Copyright © 2021 Pivotal Software, Inc.. All rights reserved.