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, org.springframework.cloud.dataflow.schema.service.SchemaService schemaService, JobServiceContainer jobServiceContainer, Environment environment)
DataflowJobExecutionDaoContainer	dataflowJobExecutionDao(DataSource dataSource, org.springframework.cloud.dataflow.schema.service.SchemaService schemaService)
DataflowTaskExecutionDaoContainer	dataflowTaskExecutionDao(DataSource dataSource, org.springframework.cloud.dataflow.schema.service.SchemaService schemaService, org.springframework.cloud.task.configuration.TaskProperties taskProperties)
DataflowTaskExecutionMetadataDaoContainer	dataflowTaskExecutionMetadataDao(DataSource dataSource, org.springframework.cloud.dataflow.schema.service.SchemaService schemaService)
JobExecutionDaoContainer	jobExecutionDaoContainer(DataSource dataSource, org.springframework.cloud.dataflow.schema.service.SchemaService schemaService)
JobExplorerContainer	jobExplorerContainer(DataSource dataSource, org.springframework.cloud.dataflow.schema.service.SchemaService schemaService)
JobRepositoryContainer	jobRepositoryContainer(DataSource dataSource, PlatformTransactionManager platformTransactionManager, org.springframework.cloud.dataflow.schema.service.SchemaService schemaService)
JobServiceContainer	jobServiceContainer(DataSource dataSource, PlatformTransactionManager platformTransactionManager, org.springframework.cloud.dataflow.schema.service.SchemaService schemaService, JobRepositoryContainer jobRepositoryContainer, JobExplorerContainer jobExplorerContainer, Environment environment)
TaskBatchDaoContainer	taskBatchDaoContainer(DataSource dataSource, org.springframework.cloud.dataflow.schema.service.SchemaService schemaService)
org.springframework.cloud.dataflow.aggregate.task.TaskDefinitionReader	taskDefinitionReader(TaskDefinitionRepository repository)
org.springframework.cloud.dataflow.aggregate.task.TaskDeploymentReader	taskDeploymentReader(TaskDeploymentRepository repository)
TaskExecutionDaoContainer	taskExecutionDaoContainer(DataSource dataSource, org.springframework.cloud.dataflow.schema.service.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,
                                                                      org.springframework.cloud.dataflow.schema.service.SchemaService schemaService)

dataflowTaskExecutionDao

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

dataflowTaskExecutionMetadataDao

@Bean
public DataflowTaskExecutionMetadataDaoContainer dataflowTaskExecutionMetadataDao(DataSource dataSource,
                                                                                        org.springframework.cloud.dataflow.schema.service.SchemaService schemaService)

taskExecutionDaoContainer

@Bean
public TaskExecutionDaoContainer taskExecutionDaoContainer(DataSource dataSource,
                                                                 org.springframework.cloud.dataflow.schema.service.SchemaService schemaService)

jobRepositoryContainer

@Bean
public JobRepositoryContainer jobRepositoryContainer(DataSource dataSource,
                                                           PlatformTransactionManager platformTransactionManager,
                                                           org.springframework.cloud.dataflow.schema.service.SchemaService schemaService)

jobExplorerContainer

@Bean
public JobExplorerContainer jobExplorerContainer(DataSource dataSource,
                                                       org.springframework.cloud.dataflow.schema.service.SchemaService schemaService)

jobServiceContainer

@Bean
public JobServiceContainer jobServiceContainer(DataSource dataSource,
                                                     PlatformTransactionManager platformTransactionManager,
                                                     org.springframework.cloud.dataflow.schema.service.SchemaService schemaService,
                                                     JobRepositoryContainer jobRepositoryContainer,
                                                     JobExplorerContainer jobExplorerContainer,
                                                     Environment environment)

jobExecutionDaoContainer

@Bean
public JobExecutionDaoContainer jobExecutionDaoContainer(DataSource dataSource,
                                                               org.springframework.cloud.dataflow.schema.service.SchemaService schemaService)

taskDefinitionReader

@Bean
 @ConditionalOnMissingBean
public org.springframework.cloud.dataflow.aggregate.task.TaskDefinitionReader taskDefinitionReader(TaskDefinitionRepository repository)

taskDeploymentReader

@Bean
 @ConditionalOnMissingBean
public org.springframework.cloud.dataflow.aggregate.task.TaskDeploymentReader taskDeploymentReader(TaskDeploymentRepository repository)

aggregateJobQueryDao

@Bean
public AggregateJobQueryDao aggregateJobQueryDao(DataSource dataSource,
                                                       org.springframework.cloud.dataflow.schema.service.SchemaService schemaService,
                                                       JobServiceContainer jobServiceContainer,
                                                       Environment environment)
                                                throws Exception

Throws:

Exception

taskBatchDaoContainer

@Bean
public TaskBatchDaoContainer taskBatchDaoContainer(DataSource dataSource,
                                                         org.springframework.cloud.dataflow.schema.service.SchemaService schemaService)