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.
|
createHandlerInternal, getBeanFactory, getObject, getObjectType, getPreCreationHandlerType, isSingleton, setAdviceChain, setApplicationContext, setApplicationEventPublisher, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setOrder, setOutputChannel
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>