org.springframework.data.hadoop.cascading
Class HadoopFlowFactoryBean

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

All Implemented Interfaces:

BeanNameAware, FactoryBean<HadoopFlow>, InitializingBean

public class HadoopFlowFactoryBean
extends Object
implements InitializingBean, BeanNameAware, FactoryBean<HadoopFlow>

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

Author:

Costin Leau

Constructor Summary

HadoopFlowFactoryBean()

Method Summary

void	afterPropertiesSet()
HadoopFlow	getObject()
Class<?>	getObjectType()
boolean	isSingleton()
void	setBeanName(String name)
void	setConfiguration(Configuration configuration) Sets the configuration.
void	setJobPoolingInterval(Long jobPoolingInterval) Sets the job pooling interval.
void	setListeners(Collection<FlowListener> listeners) Sets the listeners.
void	setMaxConcurrentSteps(Integer maxConcurrentSteps) Sets the max concurrent steps.
void	setProperties(Properties properties) Sets the properties.
void	setSink(Tap sink)
void	setSinks(Map<String,Tap> sinks) Sets the sinks.
void	setSkipStrategy(FlowSkipStrategy skipStrategy) Sets the skip strategy.
void	setSource(Tap source)
void	setSources(Map<String,Tap> sources) Sets the sources.
void	setStepStrategy(FlowStepStrategy stepStrategy) Sets the step strategy.
void	setTail(Pipe tail) Sets the tail.
void	setTails(Collection<Pipe> tails) Sets the tails.
void	setTraps(Map<String,Tap> traps) Sets the traps.

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopFlowFactoryBean

public HadoopFlowFactoryBean()

Method Detail

getObject

public HadoopFlow getObject()

Specified by:

getObject in interface FactoryBean<HadoopFlow>

getObjectType

public Class<?> getObjectType()

Specified by:

getObjectType in interface FactoryBean<HadoopFlow>

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface FactoryBean<HadoopFlow>

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface InitializingBean

Throws:

Exception

setBeanName

public void setBeanName(String name)

Specified by:

setBeanName in interface BeanNameAware

setSkipStrategy

public void setSkipStrategy(FlowSkipStrategy skipStrategy)

Sets the skip strategy.

Parameters:

skipStrategy - The skipStrategy 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.

setMaxConcurrentSteps

public void setMaxConcurrentSteps(Integer maxConcurrentSteps)

Sets the max concurrent steps.

Parameters:

maxConcurrentSteps - The maxConcurrentSteps to set.

setJobPoolingInterval

public void setJobPoolingInterval(Long jobPoolingInterval)

Sets the job pooling interval.

Parameters:

jobPoolingInterval - The jobPoolingInterval 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.

setSources

public void setSources(Map<String,Tap> sources)

Sets the sources.

Parameters:

sources - The sources to set.

setSource

public void setSource(Tap source)

setSinks

public void setSinks(Map<String,Tap> sinks)

Sets the sinks.

Parameters:

sinks - The sinks to set.

setSink

public void setSink(Tap sink)

setTraps

public void setTraps(Map<String,Tap> traps)

Sets the traps.

Parameters:

traps - The traps to set.

setTails

public void setTails(Collection<Pipe> tails)

Sets the tails.

Parameters:

tails - The tails to set.

setTail

public void setTail(Pipe tail)

Sets the tail.

Parameters:

tail - the new tail