org.springframework.cloud.stream.app.hdfs.sink

Class HdfsSinkConfiguration

java.lang.Object

org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkConfiguration

@EnableBinding(value=org.springframework.cloud.stream.messaging.Sink.class)
 @EnableConfigurationProperties(value=HdfsSinkProperties.class)
public class HdfsSinkConfiguration
extends Object

Configuration class for the HdfsSink. Delegates to a 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.

Author:

Thomas Risberg

Field Summary

Fields

Modifier and Type	Field and Description
static String	TASK_EXECUTOR_BEAN
static String	TASK_SCHEDULER_BEAN

Constructor Summary

Constructors

Constructor and Description
HdfsSinkConfiguration()

Method Summary

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()

Methods inherited from class java.lang.Object

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

Field Detail

TASK_SCHEDULER_BEAN

public static final String TASK_SCHEDULER_BEAN

See Also:

Constant Field Values

TASK_EXECUTOR_BEAN

public static final String TASK_EXECUTOR_BEAN

See Also:

Constant Field Values

Constructor Detail

HdfsSinkConfiguration

public HdfsSinkConfiguration()

Method Detail

taskScheduler

@Bean(value="hdfsSinkTaskScheduler")
public org.springframework.scheduling.TaskScheduler taskScheduler()

taskExecutor

@Bean(value="TASK_EXECUTOR_BEAN")
public org.springframework.core.task.TaskExecutor taskExecutor()

dataStoreWriter

@Bean
public DataStoreWriterFactoryBean dataStoreWriter()

setDataStoreWriter

@Autowired
public void setDataStoreWriter(org.springframework.cloud.stream.app.hdfs.hadoop.store.DataStoreWriter<String> dataStoreWriter)

hdfsSink

@ServiceActivator(inputChannel="input")
public void hdfsSink(@Payload
                                                             String payload)