Package nz.org.riskscape.engine.pipeline
package nz.org.riskscape.engine.pipeline
-
ClassDescriptionCollector<T>Realized interface for a functor that can arbitrarily transform one set of tuples in to another.A set of characteristics a collector can have which allow the
PipelineExecutorto better optimise and organize execution.Implements a simple single-threaded collection of results from a CollectorVarious bits associated with the realization and execution of a pipelineVarious options that apply toPipelineExecutor#execute(RealizedPipeline, ExecutionOptions)Returned fromPipelineExecutor#execute(RealizedPipeline, ExecutionOptions).metadata from the execution of a pipelineAStepthat uses another pipeline as part of its processing.Used to track the construction state of this step, as we have to do a bit of collaboration across components to successfully build and validate pipeline steps that nest a child pipeline.A user-configurable data processing pipeline for performing hazard analysis.Thrown when a cycle is detected in a pipelineThrown byPipelinewhen adding edges or steps to a pipeline.Factory for producing problems that involve pipelines or pipeline steps.Marker interface for other interfaces that can be returned from aStep.realize(RealizationInput).AStepthat has been realized, such that it has produced valid output.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.