org.springframework.cloud.dataflow.aggregate.task

Class AggregateTaskConfiguration

java.lang.Object

org.springframework.cloud.dataflow.aggregate.task.AggregateTaskConfiguration

@Configuration
 @Import(value=org.springframework.cloud.dataflow.schema.service.SchemaServiceConfiguration.class)
public class AggregateTaskConfiguration
extends Object

Configuration for aggregate task related components.

Author:

Corneil du Plessis

Constructor Summary

Constructors

Constructor and Description
AggregateTaskConfiguration()

Method Summary

Modifier and Type	Method and Description
AggregateExecutionSupport	aggregateExecutionSupport(AppRegistryService registryService, SchemaService schemaService)
AggregateTaskExplorer	aggregateTaskExplorer(DataSource dataSource, DataflowTaskExecutionQueryDao taskExecutionQueryDao, SchemaService schemaService, AggregateExecutionSupport aggregateExecutionSupport, TaskDefinitionReader taskDefinitionReader, TaskDeploymentReader taskDeploymentReader)
DataflowTaskExecutionQueryDao	dataflowTaskExecutionQueryDao(DataSource dataSource, SchemaService schemaService)
void	setup()
TaskRepositoryContainer	taskRepositoryContainer(DataSource dataSource, SchemaService schemaService)

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregateTaskConfiguration

public AggregateTaskConfiguration()

Method Detail

dataflowTaskExecutionQueryDao

@Bean
public DataflowTaskExecutionQueryDao dataflowTaskExecutionQueryDao(DataSource dataSource,
                                                                         SchemaService schemaService)

aggregateExecutionSupport

@Bean
public AggregateExecutionSupport aggregateExecutionSupport(AppRegistryService registryService,
                                                                 SchemaService schemaService)

taskRepositoryContainer

@Bean
public TaskRepositoryContainer taskRepositoryContainer(DataSource dataSource,
                                                             SchemaService schemaService)

aggregateTaskExplorer

@Bean
public AggregateTaskExplorer aggregateTaskExplorer(DataSource dataSource,
                                                         DataflowTaskExecutionQueryDao taskExecutionQueryDao,
                                                         SchemaService schemaService,
                                                         AggregateExecutionSupport aggregateExecutionSupport,
                                                         TaskDefinitionReader taskDefinitionReader,
                                                         TaskDeploymentReader taskDeploymentReader)

setup

@PostConstruct
public void setup()