org.springframework.xd.integration.hadoop.config

Class StoreWriterFactoryBean

java.lang.Object

org.springframework.xd.integration.hadoop.config.StoreWriterFactoryBean

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.FactoryBean<org.springframework.data.hadoop.store.DataStoreWriter<?>>, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle

public class StoreWriterFactoryBean
extends java.lang.Object
implements org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.FactoryBean<org.springframework.data.hadoop.store.DataStoreWriter<?>>, org.springframework.beans.factory.BeanFactoryAware, org.springframework.context.Lifecycle

A FactoryBean creating a DataStoreWriter. Created writer will be either PartitionTextFileWriter or TextFileWriter depending whether partition path expression is set.

Author:

Janne Valkealahti, Gary Russell

Constructor Summary

Constructors

Constructor and Description
StoreWriterFactoryBean()

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPropertiesSet()
void	destroy()
org.springframework.data.hadoop.store.DataStoreWriter<?>	getObject()
java.lang.Class<?>	getObjectType()
boolean	isRunning()
boolean	isSingleton()
void	setBasePath(org.apache.hadoop.fs.Path basePath) Sets the base path for the writer.
void	setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
void	setCloseTimeout(long closeTimeout) Sets the close timeout for the writer.
void	setCodec(org.springframework.data.hadoop.store.codec.CodecInfo codec) Sets the codec for the writer.
void	setConfiguration(org.apache.hadoop.conf.Configuration configuration) Sets the hadoop configuration for the writer.
void	setFileOpenAttempts(int fileOpenAttempts) Sets the file open attempts for the writer.
void	setIdleTimeout(long idleTimeout) Sets the idle timeout for the writer.
void	setIntegrationEvaluationContext(org.springframework.expression.EvaluationContext evaluationContext)
void	setInUsePrefix(java.lang.String inUsePrefix) Sets the in use prefix for the writer.
void	setInUseSuffix(java.lang.String inUseSuffix) Sets the in use suffix for the writer.
void	setNamingStrategy(org.springframework.data.hadoop.store.strategy.naming.FileNamingStrategy fileNamingStrategy) Sets the naming strategy.
void	setOverwrite(boolean overwrite) Sets the file overwrite flag for the writer.
void	setPartitionExpression(java.lang.String partitionExpression) Sets the partition expression.
void	setRolloverStrategy(org.springframework.data.hadoop.store.strategy.rollover.RolloverStrategy rolloverStrategy) Sets the rollover strategy.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

StoreWriterFactoryBean

public StoreWriterFactoryBean()

Method Detail

setBeanFactory

public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
                    throws org.springframework.beans.BeansException

Specified by:

setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAware

Throws:

org.springframework.beans.BeansException

getObject

public org.springframework.data.hadoop.store.DataStoreWriter<?> getObject()
                                                                   throws java.lang.Exception

Specified by:

getObject in interface org.springframework.beans.factory.FactoryBean<org.springframework.data.hadoop.store.DataStoreWriter<?>>

Throws:

java.lang.Exception

getObjectType

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

Specified by:

getObjectType in interface org.springframework.beans.factory.FactoryBean<org.springframework.data.hadoop.store.DataStoreWriter<?>>

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface org.springframework.beans.factory.FactoryBean<org.springframework.data.hadoop.store.DataStoreWriter<?>>

destroy

public void destroy()
             throws java.lang.Exception

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Throws:

java.lang.Exception

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

java.lang.Exception

isRunning

public boolean isRunning()

Specified by:

isRunning in interface org.springframework.context.Lifecycle

start

public void start()

Specified by:

start in interface org.springframework.context.Lifecycle

stop

public void stop()

Specified by:

stop in interface org.springframework.context.Lifecycle

setIntegrationEvaluationContext

public void setIntegrationEvaluationContext(org.springframework.expression.EvaluationContext evaluationContext)

setConfiguration

public void setConfiguration(org.apache.hadoop.conf.Configuration configuration)

Sets the hadoop configuration for the writer.

Parameters:

configuration - the new configuration

setBasePath

public void setBasePath(org.apache.hadoop.fs.Path basePath)

Sets the base path for the writer.

Parameters:

basePath - the new base path

setCodec

public void setCodec(org.springframework.data.hadoop.store.codec.CodecInfo codec)

Sets the codec for the writer.

Parameters:

codec - the new codec

setIdleTimeout

public void setIdleTimeout(long idleTimeout)

Sets the idle timeout for the writer.

Parameters:

idleTimeout - the new idle timeout

setCloseTimeout

public void setCloseTimeout(long closeTimeout)

Sets the close timeout for the writer.

Parameters:

closeTimeout - the new close timeout

setInUseSuffix

public void setInUseSuffix(java.lang.String inUseSuffix)

Sets the in use suffix for the writer.

Parameters:

inUseSuffix - the new in use suffix

setInUsePrefix

public void setInUsePrefix(java.lang.String inUsePrefix)

Sets the in use prefix for the writer.

Parameters:

inUsePrefix - the new in use prefix

setOverwrite

public void setOverwrite(boolean overwrite)

Sets the file overwrite flag for the writer.

Parameters:

overwrite - the new overwrite

setPartitionExpression

public void setPartitionExpression(java.lang.String partitionExpression)

Sets the partition expression. This expression is used to determine if this factory creates an instance of PartitionTextFileWriter or TextFileWriter. Validity of this spel expression is not checked in this factory, thus any non empty string will result creation of PartitionTextFileWriter.

Parameters:

partitionExpression - the new partition expression

setFileOpenAttempts

public void setFileOpenAttempts(int fileOpenAttempts)

Sets the file open attempts for the writer.

Parameters:

fileOpenAttempts - the new file open attempts

setNamingStrategy

public void setNamingStrategy(org.springframework.data.hadoop.store.strategy.naming.FileNamingStrategy fileNamingStrategy)

Sets the naming strategy.

Parameters:

fileNamingStrategy - the new naming strategy

setRolloverStrategy

public void setRolloverStrategy(org.springframework.data.hadoop.store.strategy.rollover.RolloverStrategy rolloverStrategy)

Sets the rollover strategy.

Parameters:

rolloverStrategy - the new rollover strategy