|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Pipeline | |
---|---|
org.apache.commons.pipeline | This package provides a set of pipeline utilities designed around work queues that run in parallel to sequentially process data objects. |
org.apache.commons.pipeline.config | This package provides utilities for creating executing a pipeline using Digester. |
org.apache.commons.pipeline.validation | Utilities for validating stage connectivity within a pipeline. |
Uses of Pipeline in org.apache.commons.pipeline |
---|
Methods in org.apache.commons.pipeline that return Pipeline | |
---|---|
Pipeline |
PipelineFactory.createPipeline()
Returns a Pipeline created by the factory. |
Pipeline |
Pipeline.getParent()
Returns the parent of this pipeline, if it is a branch |
Methods in org.apache.commons.pipeline that return types with arguments of type Pipeline | |
---|---|
Map<String,Pipeline> |
Pipeline.getBranches()
Returns an unmodifiable map of branch pipelines, keyed by branch identifier. |
Methods in org.apache.commons.pipeline with parameters of type Pipeline | |
---|---|
void |
Pipeline.addBranch(String key,
Pipeline branch)
Adds a branch to the pipeline. |
void |
PipelineLifecycleJob.onFinish(Pipeline pipeline)
This is called by the pipeline engine after all data processing has completed. |
void |
PipelineLifecycleJob.onStart(Pipeline pipeline)
This is called by the pipeline engine once the pipeline is fully configured, just prior to stage driver start. |
Uses of Pipeline in org.apache.commons.pipeline.config |
---|
Methods in org.apache.commons.pipeline.config that return Pipeline | |
---|---|
Pipeline |
DigesterPipelineFactory.createPipeline()
Creates a new pipeline based upon the configuration of this factory instance. |
Uses of Pipeline in org.apache.commons.pipeline.validation |
---|
Methods in org.apache.commons.pipeline.validation with parameters of type Pipeline | |
---|---|
List<ValidationFailure> |
SimplePipelineValidator.validate(Pipeline pipeline)
This method validates the entire structure of the pipeline, ensuring that the data produced by each stage can be consumed by the subsequent stage and/or relevant branch pipelines. |
List<ValidationFailure> |
PipelineValidator.validate(Pipeline pipeline)
Implementations of this method should validate the overall structure of the pipeline. |
List<ValidationFailure> |
SimplePipelineValidator.validateAddBranch(Pipeline pipeline,
String branchKey,
Pipeline branch)
Validate whether or not the specified branch pipeline can be added with the specified key. |
List<ValidationFailure> |
PipelineValidator.validateAddBranch(Pipeline pipeline,
String branchKey,
Pipeline branch)
Implementations of this method should validate whether or not the specified branch can be added to the specified pipeline with the given key. |
List<ValidationFailure> |
SimplePipelineValidator.validateAddStage(Pipeline pipeline,
Stage stage,
StageDriverFactory driverFactory)
Validate whether or not a stage can be added to the pipeline. |
List<ValidationFailure> |
PipelineValidator.validateAddStage(Pipeline pipeline,
Stage stage,
StageDriverFactory driverFactory)
Implementations of this method should validate whether or not the specified stage can be added to the pipeline in its current state. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |