@EnableBinding(value=org.springframework.cloud.stream.messaging.Sink.class) @EnableConfigurationProperties(value=HdfsSinkProperties.class) public class HdfsSinkConfiguration extends Object
DataStoreWriterFactoryBean
for
creating the writer used by the sink.
The configuration contains the property 'fsUri' to configure a connection to HDFS as well as the
additional properties for the sink like directory, fileName, codec etc. You can also use the
standard 'spring.hadoop.fsUri' property for specifying the HDFS connection.Constructor and Description |
---|
HdfsSinkConfiguration() |
Modifier and Type | Method and Description |
---|---|
DataStoreWriterFactoryBean |
dataStoreWriter() |
void |
hdfsSink(Object payload) |
void |
setDataStoreWriter(org.springframework.data.hadoop.store.DataStoreWriter<String> dataStoreWriter) |
org.springframework.core.task.TaskExecutor |
taskExecutor() |
org.springframework.scheduling.TaskScheduler |
taskScheduler() |
@Bean public org.springframework.scheduling.TaskScheduler taskScheduler()
@Bean @Primary public org.springframework.core.task.TaskExecutor taskExecutor()
@Bean public DataStoreWriterFactoryBean dataStoreWriter()
@Autowired public void setDataStoreWriter(org.springframework.data.hadoop.store.DataStoreWriter<String> dataStoreWriter)
@ServiceActivator(inputChannel="input") public void hdfsSink(Object payload)
Copyright © 2016 Pivotal Software, Inc.. All rights reserved.