Package cascading.flow

Interface Summary

Flow<Config>	A Flow is a logical unit of work declared by an assembly of Pipe instances connected to source and sink Tap instances.
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	Interface FlowSkipStrategy is used to create new strategies that decide when a Flow should be skipped when executed in a Cascade.
FlowStep<Config>	Class FlowStep is an internal representation of a given "job" possibly to be executed on a remote cluster.
FlowStepStrategy<Config>	The FlowStepStrategy interface allows for on the fly customization of FlowStep configuration values before they are submitted to the underlying platform.

Class Summary

BaseFlow<Config>
BaseFlow.FlowHolder	Class FlowHolder is a helper class for wrapping Flow instances.
FailingFlowListener
FlowConnector	Class FlowConnector is the base class for all platform planners.
FlowConnectorProps	The class FlowConnectorProps is a fluent helper class for setting FlowConnector specific properties through the FlowConnector constructor.
FlowDef	Class FlowDef is a fluent interface for defining a Flow.
FlowProcess<Config>	FlowProcess implementations provide a call-back interface into the current computing system.
FlowProcess.NullFlowProcess
FlowProcessWrapper<Config>
FlowProps	Class FlowProps is a fluent helper class for setting Flow specific properties through a FlowConnector.
Flows	Flows is a utility helper class.
FlowSession	FlowSession implementations provide a call-back interface into the current flow management system, if any.
FlowSkipIfSinkExists	Class FlowSkipIfSinkExists is a FlowSkipStrategy implementation that returns true if the Flow sink exists, regardless if it is stale or not.
FlowSkipIfSinkNotStale	Class FlowSkipIfSinkNotStale is a FlowSkipStrategy implementation that returns true if the Flow sink exists and is not stale in relation to the Flow sources.
LockingFlowListener

Enum Summary

FailingFlowListener.OnFail
SliceCounters
StepCounters	Enum StepCounters lists all counters

Exception Summary

FlowException

FlowException instances are thrown on errors when executing a Flow.