org.springframework.cloud.dataflow.server.config

Class AggregateDataFlowTaskConfiguration

java.lang.Object

org.springframework.cloud.dataflow.server.config.AggregateDataFlowTaskConfiguration

@Configuration
public class AggregateDataFlowTaskConfiguration
extends Object

Configuration for DAO Containers use for multiple schema targets.

Author:

Corneil du Plessis

Constructor Summary

Constructors

Constructor and Description
AggregateDataFlowTaskConfiguration()

Method Summary

Modifier and Type	Method and Description
AggregateJobQueryDao	aggregateJobQueryDao(DataSource dataSource, SchemaService schemaService, JobServiceContainer jobServiceContainer, org.springframework.core.env.Environment environment)
DataflowJobExecutionDaoContainer	dataflowJobExecutionDao(DataSource dataSource, SchemaService schemaService)
DataflowTaskExecutionDaoContainer	dataflowTaskExecutionDao(DataSource dataSource, SchemaService schemaService, org.springframework.cloud.task.configuration.TaskProperties taskProperties)
DataflowTaskExecutionMetadataDaoContainer	dataflowTaskExecutionMetadataDao(DataSource dataSource, SchemaService schemaService)
JobExecutionDaoContainer	jobExecutionDaoContainer(DataSource dataSource, SchemaService schemaService)
JobExplorerContainer	jobExplorerContainer(DataSource dataSource, SchemaService schemaService)
JobRepositoryContainer	jobRepositoryContainer(DataSource dataSource, org.springframework.transaction.PlatformTransactionManager platformTransactionManager, SchemaService schemaService)
JobServiceContainer	jobServiceContainer(DataSource dataSource, org.springframework.transaction.PlatformTransactionManager platformTransactionManager, SchemaService schemaService, JobRepositoryContainer jobRepositoryContainer, JobExplorerContainer jobExplorerContainer, org.springframework.core.env.Environment environment)
TaskBatchDaoContainer	taskBatchDaoContainer(DataSource dataSource, SchemaService schemaService)
TaskDefinitionReader	taskDefinitionReader(TaskDefinitionRepository repository)
TaskDeploymentReader	taskDeploymentReader(TaskDeploymentRepository repository)
TaskExecutionDaoContainer	taskExecutionDaoContainer(DataSource dataSource, SchemaService schemaService)

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregateDataFlowTaskConfiguration

public AggregateDataFlowTaskConfiguration()

Method Detail

dataflowJobExecutionDao

@Bean
public DataflowJobExecutionDaoContainer dataflowJobExecutionDao(DataSource dataSource,
                                                                      SchemaService schemaService)

dataflowTaskExecutionDao

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

dataflowTaskExecutionMetadataDao

@Bean
public DataflowTaskExecutionMetadataDaoContainer dataflowTaskExecutionMetadataDao(DataSource dataSource,
                                                                                        SchemaService schemaService)

taskExecutionDaoContainer

@Bean
public TaskExecutionDaoContainer taskExecutionDaoContainer(DataSource dataSource,
                                                                 SchemaService schemaService)

jobRepositoryContainer

@Bean
public JobRepositoryContainer jobRepositoryContainer(DataSource dataSource,
                                                           org.springframework.transaction.PlatformTransactionManager platformTransactionManager,
                                                           SchemaService schemaService)

jobExplorerContainer

@Bean
public JobExplorerContainer jobExplorerContainer(DataSource dataSource,
                                                       SchemaService schemaService)

jobServiceContainer

@Bean
public JobServiceContainer jobServiceContainer(DataSource dataSource,
                                                     org.springframework.transaction.PlatformTransactionManager platformTransactionManager,
                                                     SchemaService schemaService,
                                                     JobRepositoryContainer jobRepositoryContainer,
                                                     JobExplorerContainer jobExplorerContainer,
                                                     org.springframework.core.env.Environment environment)

jobExecutionDaoContainer

@Bean
public JobExecutionDaoContainer jobExecutionDaoContainer(DataSource dataSource,
                                                               SchemaService schemaService)

taskDefinitionReader

@Bean
 @ConditionalOnMissingBean
public TaskDefinitionReader taskDefinitionReader(TaskDefinitionRepository repository)

taskDeploymentReader

@Bean
 @ConditionalOnMissingBean
public TaskDeploymentReader taskDeploymentReader(TaskDeploymentRepository repository)

aggregateJobQueryDao

@Bean
public AggregateJobQueryDao aggregateJobQueryDao(DataSource dataSource,
                                                       SchemaService schemaService,
                                                       JobServiceContainer jobServiceContainer,
                                                       org.springframework.core.env.Environment environment)
                                                throws Exception

Throws:

Exception

taskBatchDaoContainer

@Bean
public TaskBatchDaoContainer taskBatchDaoContainer(DataSource dataSource,
                                                         SchemaService schemaService)