org.springframework.data.hadoop.cascading
Class MapReduceFlowFactoryBean

java.lang.Object
  org.springframework.data.hadoop.cascading.MapReduceFlowFactoryBean

All Implemented Interfaces:

BeanNameAware, FactoryBean<MapReduceFlow>, InitializingBean

public class MapReduceFlowFactoryBean
extends Object
implements InitializingBean, BeanNameAware, FactoryBean<MapReduceFlow>

Factory for declarative MapReduceFlow creation. Usually used with a Cascade. Note the flow is not started.

Author:

Costin Leau

Constructor Summary

MapReduceFlowFactoryBean()

Method Summary

void	afterPropertiesSet()
MapReduceFlow	getObject()
Class<?>	getObjectType()
boolean	isSingleton()
void	setBeanName(String name)
void	setConfiguration(Configuration configuration) Sets the configuration.
void	setDeleteSinkOnInit(boolean deleteSinkOnInit) Sets the delete sink on init.
void	setJob(Job job) Sets the Hadoop job (as an alternative to setting a configuration).
void	setProperties(Properties properties) Sets the properties.

Methods inherited from class java.lang.Object

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

Constructor Detail

MapReduceFlowFactoryBean

public MapReduceFlowFactoryBean()

Method Detail

getObject

public MapReduceFlow getObject()

Specified by:

getObject in interface FactoryBean<MapReduceFlow>

getObjectType

public Class<?> getObjectType()

Specified by:

getObjectType in interface FactoryBean<MapReduceFlow>

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface FactoryBean<MapReduceFlow>

setBeanName

public void setBeanName(String name)

Specified by:

setBeanName in interface BeanNameAware

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface InitializingBean

Throws:

Exception

setJob

public void setJob(Job job)

Sets the Hadoop job (as an alternative to setting a configuration).

Parameters:

job - The job to set.

setConfiguration

public void setConfiguration(Configuration configuration)

Sets the configuration.

Parameters:

configuration - The configuration to set.

setProperties

public void setProperties(Properties properties)

Sets the properties.

Parameters:

properties - The properties to set.

setDeleteSinkOnInit

public void setDeleteSinkOnInit(boolean deleteSinkOnInit)

Sets the delete sink on init.

Parameters:

deleteSinkOnInit - The deleteSinkOnInit to set.