org.springframework.xd.integration.hadoop.config

Class HdfsWritingMessageHandlerFactoryBean

java.lang.Object

org.springframework.xd.integration.hadoop.config.HdfsWritingMessageHandlerFactoryBean

All Implemented Interfaces:

org.springframework.beans.factory.FactoryBean<HdfsWritingMessageHandler>

public class HdfsWritingMessageHandlerFactoryBean
extends java.lang.Object
implements org.springframework.beans.factory.FactoryBean<HdfsWritingMessageHandler>

Factory bean used to create HdfsWritingMessageHandler

Author:

Mark Fisher

Constructor Summary

Constructors

Constructor and Description
HdfsWritingMessageHandlerFactoryBean(org.apache.hadoop.fs.FileSystem fileSystem)

Method Summary

Methods

Modifier and Type	Method and Description
HdfsWritingMessageHandler	getObject()
java.lang.Class<?>	getObjectType()
boolean	isSingleton()
void	setAutoStartup(boolean autoStartup)
void	setBaseFilename(java.lang.String baseFilename)
void	setBasePath(java.lang.String basePath)
void	setFileSuffix(java.lang.String fileSuffix)
void	setRolloverThresholdInBytes(long rolloverThresholdInBytes)

Methods inherited from class java.lang.Object

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

Constructor Detail

HdfsWritingMessageHandlerFactoryBean

public HdfsWritingMessageHandlerFactoryBean(org.apache.hadoop.fs.FileSystem fileSystem)

Method Detail

setBasePath

public void setBasePath(java.lang.String basePath)

setBaseFilename

public void setBaseFilename(java.lang.String baseFilename)

setFileSuffix

public void setFileSuffix(java.lang.String fileSuffix)

setRolloverThresholdInBytes

public void setRolloverThresholdInBytes(long rolloverThresholdInBytes)

setAutoStartup

public void setAutoStartup(boolean autoStartup)

getObjectType

public java.lang.Class<?> getObjectType()

Specified by:

getObjectType in interface org.springframework.beans.factory.FactoryBean<HdfsWritingMessageHandler>

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface org.springframework.beans.factory.FactoryBean<HdfsWritingMessageHandler>

getObject

public HdfsWritingMessageHandler getObject()
                                    throws java.lang.Exception

Specified by:

getObject in interface org.springframework.beans.factory.FactoryBean<HdfsWritingMessageHandler>

Throws:

java.lang.Exception