@Configuration @EnableConfigurationProperties(value={GpfdistSinkProperties.class,HostInfoDiscoveryProperties.class}) @EnableBinding(value=org.springframework.cloud.stream.messaging.Sink.class) public class GpfdistSinkConfiguration extends Object
Constructor and Description |
---|
GpfdistSinkConfiguration() |
Modifier and Type | Method and Description |
---|---|
GreenplumDataSourceFactoryBean |
dataSource(ControlFile controlFile) |
GpfdistMessageHandler |
gpfdist(GreenplumLoad greenplumLoad,
org.springframework.scheduling.TaskScheduler sqlTaskScheduler,
org.springframework.data.hadoop.util.net.HostInfoDiscovery hostInfoDiscovery) |
ControlFileFactoryBean |
greenplumControlFile() |
LoadFactoryBean |
greenplumLoad(LoadConfiguration loadConfiguration,
DataSource dataSource) |
LoadConfigurationFactoryBean |
greenplumLoadConfiguration(ReadableTable externalTable,
ControlFile controlFile) |
ReadableTableFactoryBean |
greenplumReadableTable(ControlFile controlFile,
org.springframework.data.hadoop.util.net.HostInfoDiscovery hostInfoDiscovery) |
org.springframework.data.hadoop.util.net.HostInfoDiscovery |
hostInfoDiscovery() |
org.springframework.scheduling.TaskScheduler |
sqlTaskScheduler() |
@Bean public org.springframework.data.hadoop.util.net.HostInfoDiscovery hostInfoDiscovery()
@Bean public org.springframework.scheduling.TaskScheduler sqlTaskScheduler()
@Bean public ControlFileFactoryBean greenplumControlFile()
@Bean public GreenplumDataSourceFactoryBean dataSource(ControlFile controlFile)
@Bean public ReadableTableFactoryBean greenplumReadableTable(ControlFile controlFile, org.springframework.data.hadoop.util.net.HostInfoDiscovery hostInfoDiscovery)
@Bean public LoadConfigurationFactoryBean greenplumLoadConfiguration(ReadableTable externalTable, ControlFile controlFile)
@Bean public LoadFactoryBean greenplumLoad(LoadConfiguration loadConfiguration, DataSource dataSource)
@Bean @ServiceActivator(inputChannel="input") public GpfdistMessageHandler gpfdist(GreenplumLoad greenplumLoad, org.springframework.scheduling.TaskScheduler sqlTaskScheduler, org.springframework.data.hadoop.util.net.HostInfoDiscovery hostInfoDiscovery)
Copyright © 2016 Pivotal Software, Inc.. All rights reserved.