@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.
Modifier and Type | Field and Description |
---|---|
static String |
TASK_EXECUTOR_BEAN |
static String |
TASK_SCHEDULER_BEAN |
Constructor and Description |
---|
HdfsSinkConfiguration() |
Modifier and Type | Method and Description |
---|---|
DataStoreWriterFactoryBean |
dataStoreWriter() |
void |
hdfsSink(String payload) |
void |
setDataStoreWriter(org.springframework.cloud.stream.app.hdfs.hadoop.store.DataStoreWriter<String> dataStoreWriter) |
org.springframework.core.task.TaskExecutor |
taskExecutor() |
org.springframework.scheduling.TaskScheduler |
taskScheduler() |
public static final String TASK_SCHEDULER_BEAN
public static final String TASK_EXECUTOR_BEAN
@Bean(value="hdfsSinkTaskScheduler") public org.springframework.scheduling.TaskScheduler taskScheduler()
@Bean(value="TASK_EXECUTOR_BEAN") public org.springframework.core.task.TaskExecutor taskExecutor()
@Bean public DataStoreWriterFactoryBean dataStoreWriter()
@Autowired public void setDataStoreWriter(org.springframework.cloud.stream.app.hdfs.hadoop.store.DataStoreWriter<String> dataStoreWriter)
@ServiceActivator(inputChannel="input") public void hdfsSink(@Payload String payload)
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.