cascading.cascade
Class Cascade

java.lang.Object
  cascading.cascade.Cascade

All Implemented Interfaces:

Runnable

public class Cascade
extends Object
implements Runnable

A Cascade is an assembly of Flow instances that share or depend the same Tap instances and are executed as a single group. The most common case is where one Flow instance depends on a Tap created by a second Flow instance. This dependency chain can continue as practical.

Additionally, a Cascade allows for incremental builds of complex data processing processes. If a given source Tap is newer than a subsequent sink Tap in the assembly, the connecting Flow(s) will be executed when the Cascade executed. If all the targets (sinks) are up to date, the Cascade exits immediately and does nothing.

Nested Class Summary

protected class

Cascade.CascadeJob Class CascadeJob manages Flow execution in the current Cascade instance.

Method Summary

void	complete() Method complete begins the current Cascade process if method start() was not previously called.
CascadeStats	getCascadeStats() Method getCascadeStats returns the cascadeStats of this Cascade object.
List<Flow>	getFlows() Method getFlows returns the flows managed by this Cascade object.
String	getName() Method getName returns the name of this Cascade object.
void	run() Method run implements the Runnable run method.
void	start() Method start begins the current Cascade process.
void	stop()
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

getName

public String getName()

Method getName returns the name of this Cascade object.

Returns:

the name (type String) of this Cascade object.

getCascadeStats

public CascadeStats getCascadeStats()

Method getCascadeStats returns the cascadeStats of this Cascade object.

Returns:

the cascadeStats (type CascadeStats) of this Cascade object.

getFlows

public List<Flow> getFlows()

Method getFlows returns the flows managed by this Cascade object. The returned Flow instances will be in topological order.

Returns:

the flows (type Collection) of this Cascade object.

start

public void start()

Method start begins the current Cascade process. It returns immediately. See method complete() to block until the Cascade completes.

complete

public void complete()

Method complete begins the current Cascade process if method start() was not previously called. This method blocks until the process completes.

Throws:

RuntimeException - wrapping any exception thrown internally.

run

public void run()

Method run implements the Runnable run method.

Specified by:

run in interface Runnable

stop

public void stop()

toString

public String toString()

Overrides:

toString in class Object