|
Spring for Apache Hadoop | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
public class HadoopFlowFactoryBean
Factory for declarative HadoopFlow
creation. Usually used with a Cascade
.
Note the flow is not started.
Constructor Summary | |
---|---|
HadoopFlowFactoryBean()
|
Method Summary | |
---|---|
void |
afterPropertiesSet()
|
T |
getObject()
|
java.lang.Class<?> |
getObjectType()
|
boolean |
isSingleton()
|
void |
setAddCascadingJars(boolean addCascadingJars)
Indicates whether the Cascading library jars should be added to the flow classpath (through the DistributedCache). |
void |
setBeanName(java.lang.String name)
|
void |
setConfiguration(org.apache.hadoop.conf.Configuration configuration)
Sets the configuration. |
void |
setDefinition(cascading.flow.FlowDef flowDef)
Sets the flow definition. |
void |
setJar(org.springframework.core.io.Resource jar)
Sets the job jar (which might not be on the classpath). |
void |
setJarByClass(java.lang.Class<?> jarClass)
Determines the job jar (available on the classpath) based on the given class. |
void |
setJobPoolingInterval(java.lang.Long jobPoolingInterval)
Sets the job pooling interval. |
void |
setListeners(java.util.Collection<cascading.flow.FlowListener> listeners)
Sets the listeners. |
void |
setMaxConcurrentSteps(java.lang.Integer maxConcurrentSteps)
Sets the max concurrent steps. |
void |
setPriority(java.lang.Integer priority)
Sets the flow submit priority. |
void |
setProperties(java.util.Properties properties)
Sets the properties. |
void |
setSink(cascading.tap.Tap sink)
|
void |
setSinks(java.util.Map<java.lang.String,cascading.tap.Tap> sinks)
Sets the sinks. |
void |
setSkipStrategy(cascading.flow.FlowSkipStrategy skipStrategy)
Sets the skip strategy. |
void |
setSource(cascading.tap.Tap source)
Sets the source. |
void |
setSources(java.util.Map<java.lang.String,cascading.tap.Tap> sources)
Sets the sources. |
void |
setStepStrategy(cascading.flow.FlowStepStrategy stepStrategy)
Sets the step strategy. |
void |
setTail(cascading.pipe.Pipe tail)
Sets the tail. |
void |
setTails(java.util.Collection<cascading.pipe.Pipe> tails)
Sets the tails. |
void |
setTraps(java.util.Map<java.lang.String,cascading.tap.Tap> traps)
Sets the traps. |
void |
setWriteDOT(java.lang.String writeDOT)
Sets the write dot. |
void |
setWriteStepsDOT(java.lang.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 |
---|
public HadoopFlowFactoryBean()
Method Detail |
---|
public void setBeanName(java.lang.String name)
setBeanName
in interface org.springframework.beans.factory.BeanNameAware
public void setConfiguration(org.apache.hadoop.conf.Configuration configuration)
configuration
- The configuration to set.public void setProperties(java.util.Properties properties)
properties
- The properties to set.public void setMaxConcurrentSteps(java.lang.Integer maxConcurrentSteps)
maxConcurrentSteps
- The maxConcurrentSteps to set.public void setJobPoolingInterval(java.lang.Long jobPoolingInterval)
jobPoolingInterval
- The jobPoolingInterval to set.public void setSources(java.util.Map<java.lang.String,cascading.tap.Tap> sources)
sources
- The sources to set.public void setSource(cascading.tap.Tap source)
source
- The source to set.public void setSinks(java.util.Map<java.lang.String,cascading.tap.Tap> sinks)
sinks
- The sinks to set.public void setSink(cascading.tap.Tap sink)
public void setTraps(java.util.Map<java.lang.String,cascading.tap.Tap> traps)
traps
- The traps to set.public void setTails(java.util.Collection<cascading.pipe.Pipe> tails)
tails
- The tails to set.public void setTail(cascading.pipe.Pipe tail)
tail
- the new tailpublic void setDefinition(cascading.flow.FlowDef flowDef)
flowDef
- public void setJarByClass(java.lang.Class<?> jarClass)
jarClass
- The jarClass to set.public void setJar(org.springframework.core.io.Resource jar)
jar
- The jar to set.public void setAddCascadingJars(boolean addCascadingJars)
addCascadingJars
- whether the Cascading library jars should be added to the flow classpath or notpublic T getObject() throws java.lang.Exception
getObject
in interface org.springframework.beans.factory.FactoryBean<T extends cascading.flow.Flow<?>>
java.lang.Exception
public java.lang.Class<?> getObjectType()
getObjectType
in interface org.springframework.beans.factory.FactoryBean<T extends cascading.flow.Flow<?>>
public boolean isSingleton()
isSingleton
in interface org.springframework.beans.factory.FactoryBean<T extends cascading.flow.Flow<?>>
public void afterPropertiesSet() throws java.lang.Exception
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
java.lang.Exception
public void setSkipStrategy(cascading.flow.FlowSkipStrategy skipStrategy)
skipStrategy
- The skipStrategy to set.public void setStepStrategy(cascading.flow.FlowStepStrategy stepStrategy)
stepStrategy
- The stepStrategy to set.public void setListeners(java.util.Collection<cascading.flow.FlowListener> listeners)
listeners
- The listeners to set.public void setWriteDOT(java.lang.String writeDOT)
writeDOT
- the new write dotpublic void setWriteStepsDOT(java.lang.String writeStepsDOT)
writeStepsDOT
- the new write steps dotpublic void setPriority(java.lang.Integer priority)
priority
- flow priority
|
Spring for Apache Hadoop | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |