public class HdfsStoreMessageHandlerFactoryBean extends org.springframework.integration.config.AbstractSimpleMessageHandlerFactoryBean<HdfsStoreMessageHandler>
HdfsStoreMessageHandler
should be based on either HdfsPartitionDataStoreMessageHandler or HdfsDataStoreMessageHandler.
Choice of which HdfsStoreMessageHandler is created depends whether DataStoreWriter is
PartitionDataStoreWriter or not.| Constructor and Description |
|---|
HdfsStoreMessageHandlerFactoryBean() |
| Modifier and Type | Method and Description |
|---|---|
protected HdfsStoreMessageHandler |
createHandler() |
void |
setAutoStartup(boolean autoStartup)
Sets the auto startup.
|
void |
setStoreWriter(org.springframework.data.hadoop.store.DataStoreWriter<java.lang.String> storeWriter)
Sets the store writer.
|
public void setAutoStartup(boolean autoStartup)
autoStartup - the new auto startuppublic void setStoreWriter(org.springframework.data.hadoop.store.DataStoreWriter<java.lang.String> storeWriter)
storeWriter - the new store writerprotected HdfsStoreMessageHandler createHandler()
createHandler in class org.springframework.integration.config.AbstractSimpleMessageHandlerFactoryBean<HdfsStoreMessageHandler>