A C D E G H I M O R S

A

afterPropertiesSet() - Method in class org.springframework.data.hadoop.cascading.CascadeFactoryBean
 
afterPropertiesSet() - Method in class org.springframework.data.hadoop.cascading.CascadingRunner
 

C

call() - Method in class org.springframework.data.hadoop.cascading.CascadingRunner
 
CascadeFactoryBean - Class in org.springframework.data.hadoop.cascading
Factory for declarative Cascade creation.
CascadeFactoryBean() - Constructor for class org.springframework.data.hadoop.cascading.CascadeFactoryBean
 
CascadingRunner - Class in org.springframework.data.hadoop.cascading
Simple runner for executing Cascades or Flows.
CascadingRunner() - Constructor for class org.springframework.data.hadoop.cascading.CascadingRunner
 
CascadingTasklet - Class in org.springframework.data.hadoop.cascading
Batch tasklet for executing a Cascade as part of a job.
CascadingTasklet() - Constructor for class org.springframework.data.hadoop.cascading.CascadingTasklet
 
createResource(Properties) - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageHandlerTap
 

D

deleteResource(Properties) - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageHandlerTap
 

E

execute(StepContribution, ChunkContext) - Method in class org.springframework.data.hadoop.cascading.CascadingTasklet
 

G

getIdentifier() - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageHandlerTap
 
getIdentifier() - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageSourceTap
 
getIdentifier() - Method in class org.springframework.data.hadoop.cascading.tap.local.ResourceTap
 
getModifiedTime(Properties) - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageHandlerTap
 
getModifiedTime(Properties) - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageSourceTap
 
getModifiedTime(Properties) - Method in class org.springframework.data.hadoop.cascading.tap.local.ResourceTap
 
getObject() - Method in class org.springframework.data.hadoop.cascading.CascadeFactoryBean
 
getObjectType() - Method in class org.springframework.data.hadoop.cascading.CascadeFactoryBean
 

H

HadoopFlowFactoryBean - Class in org.springframework.data.hadoop.cascading
Factory for declarative HadoopFlow creation.
HadoopFlowFactoryBean() - Constructor for class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
 

I

isSingleton() - Method in class org.springframework.data.hadoop.cascading.CascadeFactoryBean
 

M

MapReduceFlowFactoryBean - Class in org.springframework.data.hadoop.cascading
Factory for declarative MapReduceFlow creation.
MapReduceFlowFactoryBean() - Constructor for class org.springframework.data.hadoop.cascading.MapReduceFlowFactoryBean
 
MessageHandlerTap - Class in org.springframework.data.hadoop.cascading.tap.local
SinkTap on top of Spring Integration MessageHandler.
MessageHandlerTap(Scheme<Properties, ?, OutputStream, ?, ?>, MessageHandler) - Constructor for class org.springframework.data.hadoop.cascading.tap.local.MessageHandlerTap
 
MessageSourceTap - Class in org.springframework.data.hadoop.cascading.tap.local
SourceTap for Spring Integration MessageSource.
MessageSourceTap(Scheme<Properties, InputStream, ?, ?, ?>, MessageSource<byte[]>) - Constructor for class org.springframework.data.hadoop.cascading.tap.local.MessageSourceTap
Constructs a new MessageSourceTap instance.
MessageSourceTap(Scheme<Properties, InputStream, ?, ?, ?>, MessageSource<?>, Transformer) - Constructor for class org.springframework.data.hadoop.cascading.tap.local.MessageSourceTap
Constructs a new MessageSourceTap instance.

O

openForRead(FlowProcess<Properties>, InputStream) - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageSourceTap
 
openForRead(FlowProcess<Properties>, Resource) - Method in class org.springframework.data.hadoop.cascading.tap.local.ResourceTap
 
openForWrite(FlowProcess<Properties>, OutputStream) - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageHandlerTap
 
org.springframework.data.hadoop.cascading - package org.springframework.data.hadoop.cascading
Support classes for Cascading.
org.springframework.data.hadoop.cascading.tap.local - package org.springframework.data.hadoop.cascading.tap.local
Local Spring-specific Tap for Cascading library.

R

resourceExists(Properties) - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageHandlerTap
 
resourceExists(Properties) - Method in class org.springframework.data.hadoop.cascading.tap.local.MessageSourceTap
 
resourceExists(Properties) - Method in class org.springframework.data.hadoop.cascading.tap.local.ResourceTap
 
ResourceTap - Class in org.springframework.data.hadoop.cascading.tap.local
SourceTap for Spring's Resource abstraction.
ResourceTap(Scheme<Properties, Resource, ?, ?, ?>, Resource) - Constructor for class org.springframework.data.hadoop.cascading.tap.local.ResourceTap
Constructs a new ResourceTap instance.
ResourceTap(Scheme<Properties, Resource, ?, ?, ?>, Resource[]) - Constructor for class org.springframework.data.hadoop.cascading.tap.local.ResourceTap
Constructs a new ResourceTap instance.

S

setAddCascadingJars(boolean) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
Indicates whether the Cascading library jars should be added to the flow classpath (through the DistributedCache).
setBeanName(String) - Method in class org.springframework.data.hadoop.cascading.CascadeFactoryBean
 
setBeanName(String) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
 
setBeanName(String) - Method in class org.springframework.data.hadoop.cascading.MapReduceFlowFactoryBean
 
setConfiguration(Configuration) - Method in class org.springframework.data.hadoop.cascading.CascadeFactoryBean
Sets the configuration.
setConfiguration(Configuration) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
Sets the configuration.
setConfiguration(Configuration) - Method in class org.springframework.data.hadoop.cascading.MapReduceFlowFactoryBean
Sets the configuration.
setDefinition(CascadeDef) - Method in class org.springframework.data.hadoop.cascading.CascadeFactoryBean
Sets the cascade definition.
setDefinition(FlowDef) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
Sets the flow definition.
setDeleteSinkOnInit(boolean) - Method in class org.springframework.data.hadoop.cascading.MapReduceFlowFactoryBean
Sets the delete sink on init.
setFlows(Collection<Flow>) - Method in class org.springframework.data.hadoop.cascading.CascadeFactoryBean
Sets the flows.
setJar(Resource) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
Sets the job jar (which might not be on the classpath).
setJarByClass(Class<?>) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
Determines the job jar (available on the classpath) based on the given class.
setJob(Job) - Method in class org.springframework.data.hadoop.cascading.MapReduceFlowFactoryBean
Sets the Hadoop job (as an alternative to setting a configuration).
setJobPoolingInterval(Long) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
Sets the job pooling interval.
setListeners(Collection<CascadeListener>) - Method in class org.springframework.data.hadoop.cascading.CascadeFactoryBean
Sets the listeners.
setMaxConcurrentSteps(Integer) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
Sets the max concurrent steps.
setPostAction(Collection<Callable<?>>) - Method in class org.springframework.data.hadoop.cascading.CascadingRunner
Actions to be invoked after running the action.
setPreAction(Collection<Callable<?>>) - Method in class org.springframework.data.hadoop.cascading.CascadingRunner
Actions to be invoked before running the action.
setProperties(Properties) - Method in class org.springframework.data.hadoop.cascading.CascadeFactoryBean
Sets the properties.
setProperties(Properties) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
Sets the properties.
setProperties(Properties) - Method in class org.springframework.data.hadoop.cascading.MapReduceFlowFactoryBean
Sets the properties.
setRunAtStartup(boolean) - Method in class org.springframework.data.hadoop.cascading.CascadingRunner
Sets the run at startup.
setSink(Tap) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
 
setSinks(Map<String, Tap>) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
Sets the sinks.
setSource(Tap) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
Sets the source.
setSources(Map<String, Tap>) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
Sets the sources.
setTail(Pipe) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
Sets the tail.
setTails(Collection<Pipe>) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
Sets the tails.
setTraps(Map<String, Tap>) - Method in class org.springframework.data.hadoop.cascading.HadoopFlowFactoryBean
Sets the traps.

A C D E G H I M O R S