org.springframework.data.hadoop.cascading
Class CascadeFactoryBean

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

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.FactoryBean<cascading.cascade.Cascade>, org.springframework.beans.factory.InitializingBean

public class CascadeFactoryBean
extends java.lang.Object
implements org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.FactoryBean<cascading.cascade.Cascade>

Factory for declarative Cascade creation. The cascade is initialized but not started.

Author:

Costin Leau

Constructor Summary

CascadeFactoryBean()

Method Summary

void	afterPropertiesSet()
cascading.cascade.Cascade	getObject()
java.lang.Class<?>	getObjectType()
boolean	isSingleton()
void	setBeanName(java.lang.String name)
void	setConfiguration(org.apache.hadoop.conf.Configuration configuration) Sets the configuration.
void	setDefinition(cascading.cascade.CascadeDef def) Sets the cascade definition.
void	setFlows(java.util.Collection<cascading.flow.Flow> flows) Sets the flows.
void	setListeners(java.util.Collection<cascading.cascade.CascadeListener> listeners) Sets the listeners.
void	setProperties(java.util.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

CascadeFactoryBean

public CascadeFactoryBean()

Method Detail

getObject

public cascading.cascade.Cascade getObject()
                                    throws java.lang.Exception

Specified by:

getObject in interface org.springframework.beans.factory.FactoryBean<cascading.cascade.Cascade>

Throws:

java.lang.Exception

getObjectType

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

Specified by:

getObjectType in interface org.springframework.beans.factory.FactoryBean<cascading.cascade.Cascade>

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface org.springframework.beans.factory.FactoryBean<cascading.cascade.Cascade>

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception

Specified by:

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

Throws:

java.lang.Exception

setConfiguration

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

Sets the configuration.

Parameters:

configuration - the new configuration

setProperties

public void setProperties(java.util.Properties properties)

Sets the properties.

Parameters:

properties - the new properties

setBeanName

public void setBeanName(java.lang.String name)

Specified by:

setBeanName in interface org.springframework.beans.factory.BeanNameAware

setFlows

public void setFlows(java.util.Collection<cascading.flow.Flow> flows)

Sets the flows.

Parameters:

flows - The flows to set.

setDefinition

public void setDefinition(cascading.cascade.CascadeDef def)

Sets the cascade definition.

Parameters:

def - Cascade definition to use.

setListeners

public void setListeners(java.util.Collection<cascading.cascade.CascadeListener> listeners)

Sets the listeners.

Parameters:

listeners - The listeners to add.