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 BeanNameAware

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()
T	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	setListeners(Collection<FlowListener> listeners) Sets the listeners.
void	setPriority(Integer priority) Sets the flow submit priority.
void	setProperties(Properties properties) Sets the properties.
void	setSkipStrategy(FlowSkipStrategy skipStrategy) Sets the skip strategy.
void	setStepStrategy(FlowStepStrategy stepStrategy) Sets the step strategy.
void	setWriteDOT(String writeDOT) Sets the write dot.
void	setWriteStepsDOT(String writeStepsDOT) Sets the write steps dot.

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

setBeanName

public void setBeanName(String name)

Specified by:

setBeanName in interface BeanNameAware

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.

getObject

public T getObject()
                            throws Exception

Specified by:

getObject in interface FactoryBean<T extends Flow<?>>

Throws:

Exception

getObjectType

public Class<?> getObjectType()

Specified by:

getObjectType in interface FactoryBean<T extends Flow<?>>

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface FactoryBean<T extends Flow<?>>

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface InitializingBean

Throws:

Exception

setSkipStrategy

public void setSkipStrategy(FlowSkipStrategy skipStrategy)

Sets the skip strategy.

Parameters:

skipStrategy - The skipStrategy to set.

setStepStrategy

public void setStepStrategy(FlowStepStrategy stepStrategy)

Sets the step strategy.

Parameters:

stepStrategy - The stepStrategy to set.

setListeners

public void setListeners(Collection<FlowListener> listeners)

Sets the listeners.

Parameters:

listeners - The listeners to set.

setWriteDOT

public void setWriteDOT(String writeDOT)

Sets the write dot.

Parameters:

writeDOT - the new write dot

setWriteStepsDOT

public void setWriteStepsDOT(String writeStepsDOT)

Sets the write steps dot.

Parameters:

writeStepsDOT - the new write steps dot

setPriority

public void setPriority(Integer priority)

Sets the flow submit priority.

Parameters:

priority - flow priority