|
Spring for Apache Hadoop | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.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.BeanNameAwarepublic 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 not
public T getObject()
throws java.lang.Exception
getObject in interface org.springframework.beans.factory.FactoryBean<T extends cascading.flow.Flow<?>>java.lang.Exceptionpublic 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.InitializingBeanjava.lang.Exceptionpublic 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 | ||||||||