Package org.springframework.cloud.dataflow.server.config

Class DataFlowTaskConfiguration

java.lang.Object

org.springframework.cloud.dataflow.server.config.DataFlowTaskConfiguration

@Configuration
public class DataFlowTaskConfiguration
extends Object

Configuration for DAO Containers use for multiple schema targets.

Author:

Corneil du Plessis

Constructor Summary

Constructors

Constructor	Description
DataFlowTaskConfiguration()

Method Summary

Modifier and Type	Method	Description
DataflowJobExecutionDao	dataflowJobExecutionDao(DataSource dataSource)
DataflowTaskExecutionDao	dataflowTaskExecutionDao(DataSource dataSource, org.springframework.cloud.task.configuration.TaskProperties taskProperties)
DataflowTaskExecutionMetadataDao	dataflowTaskExecutionMetadataDao(DataSource dataSource)
JdbcSearchableJobExecutionDao	jobExecutionDao(DataSource dataSource)
JobService	jobService(DataSource dataSource, PlatformTransactionManager platformTransactionManager, org.springframework.batch.core.repository.JobRepository jobRepository, org.springframework.batch.core.explore.JobExplorer jobExplorer, Environment environment)
org.springframework.cloud.task.batch.listener.support.JdbcTaskBatchDao	taskBatchDao(DataSource dataSource)
TaskDefinitionReader	taskDefinitionReader(TaskDefinitionRepository repository)
TaskDeploymentReader	taskDeploymentReader(TaskDeploymentRepository repository)
org.springframework.cloud.task.repository.dao.TaskExecutionDao	taskExecutionDao(DataSource dataSource)

Methods inherited from class java.lang.Object

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

Constructor Details

DataFlowTaskConfiguration

public DataFlowTaskConfiguration()

Method Details

dataflowJobExecutionDao

@Bean
public DataflowJobExecutionDao dataflowJobExecutionDao(DataSource dataSource)

dataflowTaskExecutionDao

@Bean
public DataflowTaskExecutionDao dataflowTaskExecutionDao(DataSource dataSource,
 org.springframework.cloud.task.configuration.TaskProperties taskProperties)

dataflowTaskExecutionMetadataDao

@Bean
public DataflowTaskExecutionMetadataDao dataflowTaskExecutionMetadataDao(DataSource dataSource)
                                                                  throws SQLException

Throws:

SQLException

taskExecutionDao

@Bean
public org.springframework.cloud.task.repository.dao.TaskExecutionDao taskExecutionDao(DataSource dataSource)
                                                                                throws Exception

Throws:

Exception

jobService

@Bean
public JobService jobService(DataSource dataSource,
 PlatformTransactionManager platformTransactionManager,
 org.springframework.batch.core.repository.JobRepository jobRepository,
 org.springframework.batch.core.explore.JobExplorer jobExplorer,
 Environment environment)
                      throws Exception

Throws:

Exception

jobExecutionDao

@Bean
public JdbcSearchableJobExecutionDao jobExecutionDao(DataSource dataSource)

taskDefinitionReader

@Bean
@ConditionalOnMissingBean
public TaskDefinitionReader taskDefinitionReader(TaskDefinitionRepository repository)

taskDeploymentReader

@Bean
@ConditionalOnMissingBean
public TaskDeploymentReader taskDeploymentReader(TaskDeploymentRepository repository)

taskBatchDao

@Bean
public org.springframework.cloud.task.batch.listener.support.JdbcTaskBatchDao taskBatchDao(DataSource dataSource)