Package cascading.flow

Interface Summary

FlowCollector
FlowConstants	Interface FlowConstants ...
FlowElement	Interface FlowElement is a utility interface used internally to simplify DAG management.
FlowListener	Interface FlowListener provides hooks for receiving events on various stages of a Flow execution.
FlowSkipStrategy

Class Summary

ElementGraph	Class ElementGraph represents the executable FlowElement graph.
ElementGraph.Extent
Flow	A Pipe assembly is connected to the necessary number of Tap sinks and sources into a Flow.
Flow.FlowHolder	Class FlowHolder is a helper class for wrapping Flow instances.
FlowConnector	Use the FlowConnector to link sink and source Tap instances with an assembly of Pipe instances into an executable Flow.
FlowMapper	Class FlowMapper ...
FlowPlanner	Class FlowPlanner is the base class for all planner implementations.
FlowProcess	FlowProcess implementations provide a call-back interface into the current computing system.
FlowReducer	Class FlowReducer ...
FlowSession	FlowSession implementations provide a call-back interface into the current flow management system, if any.
FlowSkipIfSinkExists
FlowSkipIfSinkStale
FlowStep	Class FlowStep ...
MapReduceFlow	Class MapReduceFlow is a Flow subclass that supports custom MapReduce jobs preconfigured via the JobConf object.
MapReduceFlowStep	Class MapReduceFlowStep wraps a JobConf and allows it to be executed as a Flow.
MultiMapReducePlanner	Class MultiMapReducePlanner is the core Hadoop MapReduce planner.
Scope	Class Scope ...
StepGraph	Class StepGraph ...

Enum Summary

Scope.Kind

Exception Summary

ElementGraphException	Class PlannerException is thrown when a job planner fails.
FlowException	FlowException instances are thrown on errors when executing a Flow.
PlannerException	Class PlannerException is thrown when a job planner fails.