Package nz.org.riskscape.engine.pipeline

package nz.org.riskscape.engine.pipeline

Related Packages

Package	Description
nz.org.riskscape.engine

Class	Description
AutoClosingException
Collector<T>	Realized interface for a functor that can arbitrarily transform one set of tuples in to another.
Collector.Characteristic	A set of characteristics a collector can have which allow the PipelineExecutor to better optimise and organize execution.
DefaultCollection<T>	Implements a simple single-threaded collection of results from a Collector
ExecutionContext	Various bits associated with the realization and execution of a pipeline
ExecutionOptions	Various options that apply to PipelineExecutor#execute(RealizedPipeline, ExecutionOptions)
ExecutionResult	Returned from PipelineExecutor#execute(RealizedPipeline, ExecutionOptions).
Manifest	metadata from the execution of a pipeline
Manifest.LocalInfo
Manifest.OutputInfo
Manifest.StepDescription
Manifest.VersionInfo
NullStep	A Pipeline Step that does nothing.
Pipeline	A user-configurable data processing pipeline for performing hazard analysis.
Pipeline.ProblemCodes
PipelineCycleException	Thrown when a cycle is detected in a pipeline
PipelineDefinitionException	Thrown by Pipeline when adding edges or steps to a pipeline.
PipelineExecutor
PipelineProblems	Factory for producing problems that involve pipelines or pipeline steps.
PipelineRealizer	Methods for converting PipelineDeclarations in to RealizedPipelines
PipelineSteps	Collection of Steps that are available for use in Pipelines.
RealizationInput	An aggregate of the current state of pipeline realization to simplify the Step.realize(RealizationInput) method.
Realized	Interface for other interfaces that can be returned from a Step.realize(RealizationInput).
RealizedPipeline	A RealizedPipeline is the result of realizing (going from untyped to typed) a PipelineDeclaration against a project and a set of parameters via a PipelineRealizer.
RealizedStep	A Step that has been realized, such that it has produced valid output.
Sink	Accepts output tuples from a pipeline step, possibly for saving results, but also potentially for processing them before having them emerge somewhere else in the pipeline.
SinkConstructor	A SinkConstructor allows a Sink to be constructed from the set of execution time ExecutionOptions.
Step	A processing Step that can be added to a Pipeline.
TupleInput	A re-mix of TupleIterator that should work better in the scheduler