cascading.cascade
Class CascadeDef

java.lang.Object
  cascading.property.UnitOfWorkDef<CascadeDef>
      cascading.cascade.CascadeDef

public class CascadeDef
extends UnitOfWorkDef<CascadeDef>

Class CascadeDef is a fluent interface for defining a Cascade.

This allows for ad-hoc building of Cascade data and meta-data like tags.

Instead of calling one of the CascadeConnector connect methods, CascadeConnector.connect(CascadeDef) can be called.

See Also:

UnitOfWorkDef, FlowDef

Field Summary

Fields inherited from class cascading.property.UnitOfWorkDef

name, tags

Constructor Summary

CascadeDef()
Constructor CascadeDef creates a new CascadeDef instance.

Method Summary

CascadeDef	addFlow(Flow flow) Method addFlow adds a new Flow instance that is intended to participate in a Cascade.
CascadeDef	addFlows(Collection<Flow> flows) Method addFlows adds many new Flow instances intended to participate in a Cascade.
CascadeDef	addFlows(Flow... flows) Method addFlows adds many new Flow instances intended to participate in a Cascade.
static CascadeDef	cascadeDef() Creates a new instance of a CascadeDef.
Collection<Flow>	getFlows() Method getFlows returns the flows of this CascadeDef object.
Flow[]	getFlowsArray() Method getFlowsArray returns the flows as an array of this CascadeDef object.
int	getMaxConcurrentFlows()
CascadeDef	setMaxConcurrentFlows(int maxConcurrentFlows)

Methods inherited from class cascading.property.UnitOfWorkDef

addTag, addTags, getName, getTags, setName

Methods inherited from class java.lang.Object

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

Constructor Detail

CascadeDef

public CascadeDef()

Constructor CascadeDef creates a new CascadeDef instance.

Method Detail

cascadeDef

public static CascadeDef cascadeDef()

Creates a new instance of a CascadeDef.

Returns:

a CascadeDef

getFlows

public Collection<Flow> getFlows()

Method getFlows returns the flows of this CascadeDef object.

Returns:

the flows (type Collection) of this CascadeDef object.

getFlowsArray

public Flow[] getFlowsArray()

Method getFlowsArray returns the flows as an array of this CascadeDef object.

Returns:

the flowsArray (type Flow[]) of this CascadeDef object.

addFlow

public CascadeDef addFlow(Flow flow)

Method addFlow adds a new Flow instance that is intended to participate in a Cascade.

Parameters:

flow - of Flow

Returns:

CascadeDef

addFlows

public CascadeDef addFlows(Flow... flows)

Method addFlows adds many new Flow instances intended to participate in a Cascade.

Parameters:

flows - of Flow[]

Returns:

CascadeDef

addFlows

public CascadeDef addFlows(Collection<Flow> flows)

Method addFlows adds many new Flow instances intended to participate in a Cascade.

Parameters:

flows - of Collection

Returns:

CascadeDef

setMaxConcurrentFlows

public CascadeDef setMaxConcurrentFlows(int maxConcurrentFlows)

getMaxConcurrentFlows

public int getMaxConcurrentFlows()